fix: delay onFirstData until nextTick after stream action

Author: mesqueeb

packages/core/src/moduleActions/handleStreamPerStore.ts

@@ -37,7 +37,7 @@ export function handleStreamPerStore(
     if (isPromise(foundStream)) {
       // If onFirstData is provided and stream is already open, call it with existingStream flag
       if (payload?.onFirstData) {
-        payload.onFirstData({ empty: undefined, existingStream: true })
+        setTimeout(() => payload.onFirstData({ empty: undefined, existingStream: true }), 0)
       }
       return foundStream
     }

packages/plugin-firestore-admin/src/actions/stream.ts

@@ -50,7 +50,7 @@ export function streamActionFactory(
           // Call onFirstData on first snapshot (whether doc exists or not)
           if (!firstDataReceived && onFirstData) {
             firstDataReceived = true
-            onFirstData({ empty: !docSnapshot.exists })
+            setTimeout(() => onFirstData({ empty: !docSnapshot.exists }), 0)
           }
 
           // do nothing if the doc doesn't exist
@@ -74,7 +74,7 @@ export function streamActionFactory(
           // Call onFirstData on first snapshot (whether collection has docs or not)
           if (!firstDataReceived && onFirstData) {
             firstDataReceived = true
-            onFirstData({ empty: querySnapshot.empty })
+            setTimeout(() => onFirstData({ empty: querySnapshot.empty }), 0)
           }
 
           // serverChanges only

packages/plugin-firestore/src/actions/stream.ts

@@ -56,7 +56,7 @@ export function streamActionFactory(
             !docSnapshot.metadata.hasPendingWrites
           ) {
             firstDataReceived = true
-            onFirstData({ empty: !docSnapshot.exists() })
+            setTimeout(() => onFirstData({ empty: !docSnapshot.exists() }), 0)
           }
 
           // do nothing if the doc doesn't exist
@@ -88,7 +88,7 @@ export function streamActionFactory(
             !querySnapshot.metadata.hasPendingWrites
           ) {
             firstDataReceived = true
-            onFirstData({ empty: querySnapshot.empty })
+            setTimeout(() => onFirstData({ empty: querySnapshot.empty }), 0)
           }
 
           // serverChanges only

packages/test-utils/src/PluginRemoteMock/actions.ts

@@ -273,7 +273,7 @@ export function streamActionFactory(storePluginOptions: RemoteStoreOptions): Plu
             // Call onFirstData on first data processed
             if (!firstDataProcessed && onFirstData) {
               firstDataProcessed = true
-              onFirstData({ empty: false })
+              setTimeout(() => onFirstData({ empty: false }), 0)
             }
             mustExecuteOnRead.added(data, metaData)
           }
@@ -291,7 +291,7 @@ export function streamActionFactory(storePluginOptions: RemoteStoreOptions): Plu
           // Call onFirstData on first data processed
           if (!firstDataProcessed && onFirstData) {
             firstDataProcessed = true
-            onFirstData({ empty: false })
+            setTimeout(() => onFirstData({ empty: false }), 0)
           }
           mustExecuteOnRead.added(data, metaData)
         }
@@ -304,7 +304,7 @@ export function streamActionFactory(storePluginOptions: RemoteStoreOptions): Plu
       setTimeout(() => {
         if (!firstDataProcessed) {
           firstDataProcessed = true
-          onFirstData({ empty: true })
+          setTimeout(() => onFirstData({ empty: true }), 0)
         }
       }, 0)
     }