From 82f9272de0b79b14d3ddcb3a0f66e7adb0d26518 Mon Sep 17 00:00:00 2001 From: danielshaya Date: Fri, 17 Apr 2015 16:27:32 +0100 Subject: [PATCH] Use functions. --- .../map/ClientWiredStatelessChronicleMap.java | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/src/main/java/net/openhft/chronicle/map/ClientWiredStatelessChronicleMap.java b/src/main/java/net/openhft/chronicle/map/ClientWiredStatelessChronicleMap.java index f9681445d..b3139eafe 100644 --- a/src/main/java/net/openhft/chronicle/map/ClientWiredStatelessChronicleMap.java +++ b/src/main/java/net/openhft/chronicle/map/ClientWiredStatelessChronicleMap.java @@ -328,23 +328,25 @@ class ClientWiredStatelessChronicleMap extends MapStatelessClient> 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(channelName, hub, cidRef[0], vClass); + return new ClientWiredStatelessChronicleEntrySet(channelName, hub, cid, vClass); }