From af1b96ab5886af15ea640522d93fc65cd272262d Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Thu, 16 Apr 2015 18:13:12 +0100 Subject: [PATCH] CE-23 minor code cleanup --- .../net/openhft/chronicle/map/MapWireHandler.java | 11 ++--------- 1 file changed, 2 insertions(+), 9 deletions(-) diff --git a/src/main/java/net/openhft/chronicle/map/MapWireHandler.java b/src/main/java/net/openhft/chronicle/map/MapWireHandler.java index 7a3aff098..a04f5a1ee 100644 --- a/src/main/java/net/openhft/chronicle/map/MapWireHandler.java +++ b/src/main/java/net/openhft/chronicle/map/MapWireHandler.java @@ -230,12 +230,9 @@ public class MapWireHandler implements WireHandler, Consumer } final StringBuilder cspText = new StringBuilder(); - public long tid; - private final AtomicLong cid = new AtomicLong(); - /** * create a new cid if one does not already exist for this csp * @@ -337,7 +334,6 @@ public class MapWireHandler implements WireHandler, Consumer write(b -> outWire.write(reply).type("set-proxy").writeValue() .marshallable(w -> { - CharSequence root = cspText.subSequence(0, cspText .length() - "#map".length()); @@ -413,14 +409,11 @@ public class MapWireHandler implements WireHandler, Consumer final Map data = new HashMap(); writeVoid(b -> { - while (valueIn.hasNext()) { - valueIn.sequence(v -> valueIn.marshallable(wire -> data.put( - wire.read(getAndPut.params()[0]).bytes(), - wire.read(getAndPut.params()[1]).bytes()))); + wire.read(put.params()[0]).bytes(), + wire.read(put.params()[1]).bytes()))); } - b.delegate.putAll(data); });