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)) {