ignore java.util.concurrent.RejectedExecutionException when already closed

This commit is contained in:
Rob Austin
2015-07-25 16:04:29 +03:00
committed by leventov
parent c7ef524031
commit abebd13414
@@ -1191,8 +1191,12 @@ class StatelessChronicleMap<K, V> implements ChronicleMap<K, V>, 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();