#405

Committed 16 Apr 2024 05:58AM UTC coverage: 0.0% (-88.9%) from 88.866%

Build # #405

Build Type

push

Committed by

Commit Message

add encoding to fix coverage report

Run Details

0 of 5353 relevant lines covered (0.0%)

0.0 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/jetcache-core/src/main/java/com/alicp/jetcache/MultiGetResult.java

package com.alicp.jetcache;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionStage;

/**
 * Created on 2017/2/21.
 *
 * @author huangli
 */
public class MultiGetResult<K, V> extends CacheResult {
    private volatile Map<K, CacheGetResult<V>> values;

    public MultiGetResult(CompletionStage<ResultData> future) {
        super(future);
    }

    public MultiGetResult(CacheResultCode resultCode, String message, Map<K, CacheGetResult<V>> values) {
        super(CompletableFuture.completedFuture(new ResultData(resultCode, message, values)));
    }

    public MultiGetResult(Throwable e) {
        super(e);
    }

    public Map<K, CacheGetResult<V>> getValues() {
        waitForResult();
        return values;
    }

    @Override
    protected void fetchResultSuccess(ResultData resultData) {
        values = (Map<K, CacheGetResult<V>>) resultData.getOriginData();
        super.fetchResultSuccess(resultData);
    }

    @Override
    protected void fetchResultFail(Throwable e) {
        values = null;
        super.fetchResultFail(e);
    }

    public Map<K, V> unwrapValues() {
        waitForResult();
        if (values == null) {
            return null;
        }
        Map<K, V> m = new HashMap<>();
        values.entrySet().stream().forEach((en) -> {
            if (en.getValue().isSuccess()) {
                m.put(en.getKey(), en.getValue().getValue());
            }
        });
        return m;
    }
}

1	package com.alicp.jetcache;
2
3	import java.util.HashMap;
4	import java.util.Map;
5	import java.util.concurrent.CompletableFuture;
6	import java.util.concurrent.CompletionStage;
7
8	/**
9	* Created on 2017/2/21.
10	*
11	* @author huangli
12	*/
13	public class MultiGetResult<K, V> extends CacheResult {
14	private volatile Map<K, CacheGetResult<V>> values;
15
16	public MultiGetResult(CompletionStage<ResultData> future) {
17	super(future);	×
18	}	×
19
20	public MultiGetResult(CacheResultCode resultCode, String message, Map<K, CacheGetResult<V>> values) {
21	super(CompletableFuture.completedFuture(new ResultData(resultCode, message, values)));	×
22	}	×
23
24	public MultiGetResult(Throwable e) {
25	super(e);	×
26	}	×
27
28	public Map<K, CacheGetResult<V>> getValues() {
29	waitForResult();	×
30	return values;	×
31	}
32
33	@Override
34	protected void fetchResultSuccess(ResultData resultData) {
35	values = (Map<K, CacheGetResult<V>>) resultData.getOriginData();	×
36	super.fetchResultSuccess(resultData);	×
37	}	×
38
39	@Override
40	protected void fetchResultFail(Throwable e) {
41	values = null;	×
42	super.fetchResultFail(e);	×
43	}	×
44
45	public Map<K, V> unwrapValues() {
46	waitForResult();	×
47	if (values == null) {	×
48	return null;	×
49	}
50	Map<K, V> m = new HashMap<>();	×
51	values.entrySet().stream().forEach((en) -> {	×
52	if (en.getValue().isSuccess()) {	×
53	m.put(en.getKey(), en.getValue().getValue());	×
54	}
55	});	×
56	return m;	×
57	}
58	}

alibaba / jetcache / #405

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous