diff --git a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java index b76e11f8c..d93e2bf65 100644 --- a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java +++ b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java @@ -1104,12 +1104,10 @@ class TcpReplicator extends AbstractChannelReplicator implements Closeable { continue; } - if (out.remaining() < sizeInBytes) { return; } - final long nextEntryPos = out.position() + sizeInBytes; final long limit = out.limit(); out.limit(nextEntryPos);