diff --git a/aeron-cluster/src/main/java/io/aeron/cluster/DynamicJoin.java b/aeron-cluster/src/main/java/io/aeron/cluster/DynamicJoin.java
index 97c3a9ed55..15e8af983d 100644
--- a/aeron-cluster/src/main/java/io/aeron/cluster/DynamicJoin.java
+++ b/aeron-cluster/src/main/java/io/aeron/cluster/DynamicJoin.java
@@ -472,7 +472,7 @@ static class SnapshotReader implements ControlledFragmentHandler
 
         boolean isDone()
         {
-            return isDone && (endPosition <= recordingPosition);
+            return isDone && endPosition <= recordingPosition && image.isEndOfStream();
         }
 
         long recordingId()