Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

Use functions.

Browse Source
This commit is contained in:
danielshaya
2015-04-17 16:27:32 +01:00
parent 15c61e5341
commit 82f9272de0
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/ClientWiredStatelessChronicleMap.java
+8 -6
View File
@@ -328,23 +328,25 @@ class ClientWiredStatelessChronicleMap<K, V> extends MapStatelessClient<K, V, Ev
@NotNull
public Set<Map.Entry<K, V>> entrySet() {
final long[] cidRef = new long[1];
proxyReturnWireConsumer(entrySet, (WireIn wireIn) -> {
long cid = proxyReturnWireConsumer(entrySet, (WireIn wireIn) -> {
final long[] cidRef = new long[1];
final StringBuilder type = Wires.acquireStringBuilder();
final ValueIn read = wireIn.read(reply);
read.type(type);
read.marshallable(w -> {
final String csp1 = w.read(CoreFields.csp).text();
final long cid = w.read(CoreFields.cid).int64();
cidToCsp.put(cid, csp1);
cidRef[0] = cid;
final long cid0 = w.read(CoreFields.cid).int64();
cidToCsp.put(cid0, csp1);
cidRef[0] = cid0;
});
return cidRef[0];
});
return new ClientWiredStatelessChronicleEntrySet<K, V>(channelName, hub, cidRef[0], vClass);
return new ClientWiredStatelessChronicleEntrySet<K, V>(channelName, hub, cid, vClass);
}