diff --git a/src/amp/streaming/reorg.py b/src/amp/streaming/reorg.py
index 9083db7..81702b1 100644
--- a/src/amp/streaming/reorg.py
+++ b/src/amp/streaming/reorg.py
@@ -49,13 +49,6 @@ def __next__(self) -> ResponseBatch:
             # Get next batch from underlying stream
             batch = next(self.stream_iterator)
 
-            # Note: ranges_complete flag is handled by CheckpointStore in load_stream_continuous
-            # Check if this batch contains only duplicate ranges
-            if self._is_duplicate_batch(batch.metadata.ranges):
-                self.logger.debug(f'Skipping duplicate batch with ranges: {batch.metadata.ranges}')
-                # Recursively call to get the next non-duplicate batch
-                return self.__next__()
-
             # Detect reorgs by comparing with previous ranges
             invalidation_ranges = self._detect_reorg(batch.metadata.ranges)