Fix pending batch being skipped after reorg detection

Move the pending batch check to BEFORE fetching a new batch from the stream.

Previously, after a reorg was detected:
1. The data batch was stored as _pending_batch
2. A reorg batch was returned
3. On next __next__() call, a NEW batch was fetched BEFORE checking _pending_batch
4. This caused the pending batch to be lost or returned out of order

Now the pending batch check happens first, ensuring proper ordering:
reorg_batch -> pending_data_batch -> next_batch

Author: incrypto32

src/amp/streaming/reorg.py

@@ -46,6 +46,12 @@ def __next__(self) -> ResponseBatch:
             KeyboardInterrupt: When user cancels the stream
         """
         try:
+            # Check if we have a pending batch from a previous reorg detection
+            if hasattr(self, '_pending_batch'):
+                pending = self._pending_batch
+                delattr(self, '_pending_batch')
+                return pending
+
             # Get next batch from underlying stream
             batch = next(self.stream_iterator)
 
@@ -70,13 +76,6 @@ def __next__(self) -> ResponseBatch:
                 self._pending_batch = batch
                 return ResponseBatch.reorg_batch(invalidation_ranges)
 
-            # Check if we have a pending batch from a previous reorg detection
-            # REVIEW: I think we should remove this
-            if hasattr(self, '_pending_batch'):
-                pending = self._pending_batch
-                delattr(self, '_pending_batch')
-                return pending
-
             # Normal case - just return the data batch
             return batch