diff --git a/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java b/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java index 29610c33c..83c376260 100644 --- a/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java +++ b/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java @@ -1191,8 +1191,12 @@ class StatelessChronicleMap implements ChronicleMap, Closeable, Clon } else inBytes.limit(inBytes.capacity()); - // block until we have received all the bytes in this chunk - receiveBytesFromSocket(remainingBytes, timeoutTime); + try { + // block until we have received all the bytes in this chunk + receiveBytesFromSocket(remainingBytes, timeoutTime); + }catch (java.nio.channels.AsynchronousCloseException e ){ + return inBytes; + } final boolean isException = inBytes.readBoolean();