From 62d028eb4bcd2bf6fda3c2fa65985c4791d5728f Mon Sep 17 00:00:00 2001
From: Rob Austin <rob.austin@boundedbuffer.co.uk>
Date: Fri, 1 May 2015 18:36:13 +0100
Subject: [PATCH] refactored MapWireHandlerProcessor

---
 .../chronicle/map/MapWireHandlerProcessor.java      | 13 ++-----------
 1 file changed, 2 insertions(+), 11 deletions(-)

diff --git a/src/main/java/net/openhft/chronicle/map/MapWireHandlerProcessor.java b/src/main/java/net/openhft/chronicle/map/MapWireHandlerProcessor.java
index 019536140..3a6b52dba 100644
--- a/src/main/java/net/openhft/chronicle/map/MapWireHandlerProcessor.java
+++ b/src/main/java/net/openhft/chronicle/map/MapWireHandlerProcessor.java
@@ -50,7 +50,8 @@ import static net.openhft.chronicle.wire.Wires.acquireStringBuilder;
 /**
  * @author Rob Austin.
  */
-public class MapWireHandlerProcessor<K, V> implements MapWireHandler<ConcurrentMap<K, V>, K, V>,
+public class MapWireHandlerProcessor<K, V> implements
+        MapWireHandler<ConcurrentMap<K, V>, K, V>,
         Consumer<WireHandlers> {
 
     private CharSequence csp;
@@ -141,7 +142,6 @@ public class MapWireHandlerProcessor<K, V> implements MapWireHandler<ConcurrentM
     private static final Logger LOG = LoggerFactory.getLogger(MapWireHandlerProcessor.class);
 
     public static final int SIZE_OF_SIZE = ClientWiredStatelessTcpConnectionHub.SIZE_OF_SIZE;
-    private final Map<Long, Runnable> incompleteWork = new HashMap<>();
 
     private final Map<Long, CharSequence> cidToCsp;
     @NotNull
@@ -214,14 +214,6 @@ public class MapWireHandlerProcessor<K, V> implements MapWireHandler<ConcurrentM
 
                 final ValueIn valueIn = inWire.readEventName(eventName);
 
-                if (!incompleteWork.isEmpty()) {
-                    Runnable runnable = incompleteWork.get(CoreFields.tid);
-                    if (runnable != null) {
-                        runnable.run();
-                        return;
-                    }
-                }
-
                 outWire.writeDocument(true, wire -> outWire.write(CoreFields.tid).int64(tid));
 
                 writeData(out -> {
@@ -252,7 +244,6 @@ public class MapWireHandlerProcessor<K, V> implements MapWireHandler<ConcurrentM
                             final Params[] params = putIfAbsent.params();
                             final K key = wireToK.apply(wire.read(params[0]));
                             final V value = wireToV.apply(wire.read(params[1]));
-
                             final V v = map.putIfAbsent(key, value);
                             vToWire.accept(outWire.write(reply), v);