From 3a12032261afcc22c990a8607830d8b5c725ea29 Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Fri, 1 May 2015 19:03:46 +0100 Subject: [PATCH] added keySet tests --- .../chronicle/map/MapWireHandlerProcessor.java | 17 ++++++++++++++++- 1 file changed, 16 insertions(+), 1 deletion(-) diff --git a/src/main/java/net/openhft/chronicle/map/MapWireHandlerProcessor.java b/src/main/java/net/openhft/chronicle/map/MapWireHandlerProcessor.java index 3a6b52dba..1b1d15b16 100644 --- a/src/main/java/net/openhft/chronicle/map/MapWireHandlerProcessor.java +++ b/src/main/java/net/openhft/chronicle/map/MapWireHandlerProcessor.java @@ -272,7 +272,22 @@ public class MapWireHandlerProcessor implements } if (keySet.contentEquals(eventName)) { - throw new UnsupportedOperationException("todo"); + outWire.write(reply).type("set-proxy").writeValue() + + .marshallable(w -> { + CharSequence root = csp.subSequence(0, csp + .length() - "#map".length()); + + final StringBuilder csp = acquireStringBuilder() + .append(root) + .append("#keySet"); + + w.write(CoreFields.csp).text(csp); + w.write(CoreFields.cid).int64(createCid(csp)); + }); + + + return; } if (values.contentEquals(eventName)) {