fix(firestore, android): catch RejectedExecutionException in sendOnSnapshotEvent

When the Firestore native module is invalidated, snapshot listener callbacks
that are already queued on the main thread's Handler can still fire after
super.invalidate() has shut down the executor. This causes a fatal
RejectedExecutionException crash.

The existing invalidate() ordering (remove listeners before super.invalidate())
reduces but does not eliminate this race, because AsyncEventListener dispatches
via Handler.post() — the callback may already be enqueued before invalidation
begins.

Wrapping Tasks.call() in sendOnSnapshotEvent with a try-catch for
RejectedExecutionException is safe because:
- The module is being torn down; no JS listener will process the event
- The snapshot data is stale/irrelevant at this point
- This matches the standard pattern for handling executor shutdown races

Applies to both CollectionModule and DocumentModule.

Author: christian-apollo

packages/firestore/android/src/reactnative/java/io/invertase/firebase/firestore/ReactNativeFirebaseFirestoreCollectionModule.java

@@ -396,31 +396,36 @@ private void sendOnSnapshotEvent(
       int listenerId,
       QuerySnapshot querySnapshot,
       MetadataChanges metadataChanges) {
-    Tasks.call(
-            getTransactionalExecutor(Integer.toString(listenerId)),
-            () ->
-                snapshotToWritableMap(
-                    appName, databaseId, "onSnapshot", querySnapshot, metadataChanges))
-        .addOnCompleteListener(
-            task -> {
-              if (task.isSuccessful()) {
-                WritableMap body = Arguments.createMap();
-                body.putMap("snapshot", task.getResult());
-
-                ReactNativeFirebaseEventEmitter emitter =
-                    ReactNativeFirebaseEventEmitter.getSharedInstance();
-
-                emitter.sendEvent(
-                    new ReactNativeFirebaseFirestoreEvent(
-                        ReactNativeFirebaseFirestoreEvent.COLLECTION_EVENT_SYNC,
-                        body,
-                        appName,
-                        databaseId,
-                        listenerId));
-              } else {
-                sendOnSnapshotError(appName, databaseId, listenerId, task.getException());
-              }
-            });
+    try {
+      Tasks.call(
+              getTransactionalExecutor(Integer.toString(listenerId)),
+              () ->
+                  snapshotToWritableMap(
+                      appName, databaseId, "onSnapshot", querySnapshot, metadataChanges))
+          .addOnCompleteListener(
+              task -> {
+                if (task.isSuccessful()) {
+                  WritableMap body = Arguments.createMap();
+                  body.putMap("snapshot", task.getResult());
+
+                  ReactNativeFirebaseEventEmitter emitter =
+                      ReactNativeFirebaseEventEmitter.getSharedInstance();
+
+                  emitter.sendEvent(
+                      new ReactNativeFirebaseFirestoreEvent(
+                          ReactNativeFirebaseFirestoreEvent.COLLECTION_EVENT_SYNC,
+                          body,
+                          appName,
+                          databaseId,
+                          listenerId));
+                } else {
+                  sendOnSnapshotError(appName, databaseId, listenerId, task.getException());
+                }
+              });
+    } catch (java.util.concurrent.RejectedExecutionException e) {
+      // Snapshot arrived after module invalidation shut down the executor.
+      // Safe to drop — the module is being torn down and no JS listener remains.
+    }
   }
 
   private void sendOnSnapshotError(

packages/firestore/android/src/reactnative/java/io/invertase/firebase/firestore/ReactNativeFirebaseFirestoreDocumentModule.java

@@ -291,27 +291,32 @@ public void documentBatch(
 
   private void sendOnSnapshotEvent(
       String appName, String databaseId, int listenerId, DocumentSnapshot documentSnapshot) {
-    Tasks.call(getExecutor(), () -> snapshotToWritableMap(appName, databaseId, documentSnapshot))
-        .addOnCompleteListener(
-            task -> {
-              if (task.isSuccessful()) {
-                WritableMap body = Arguments.createMap();
-                body.putMap("snapshot", task.getResult());
-
-                ReactNativeFirebaseEventEmitter emitter =
-                    ReactNativeFirebaseEventEmitter.getSharedInstance();
-
-                emitter.sendEvent(
-                    new ReactNativeFirebaseFirestoreEvent(
-                        ReactNativeFirebaseFirestoreEvent.DOCUMENT_EVENT_SYNC,
-                        body,
-                        appName,
-                        databaseId,
-                        listenerId));
-              } else {
-                sendOnSnapshotError(appName, databaseId, listenerId, task.getException());
-              }
-            });
+    try {
+      Tasks.call(getExecutor(), () -> snapshotToWritableMap(appName, databaseId, documentSnapshot))
+          .addOnCompleteListener(
+              task -> {
+                if (task.isSuccessful()) {
+                  WritableMap body = Arguments.createMap();
+                  body.putMap("snapshot", task.getResult());
+
+                  ReactNativeFirebaseEventEmitter emitter =
+                      ReactNativeFirebaseEventEmitter.getSharedInstance();
+
+                  emitter.sendEvent(
+                      new ReactNativeFirebaseFirestoreEvent(
+                          ReactNativeFirebaseFirestoreEvent.DOCUMENT_EVENT_SYNC,
+                          body,
+                          appName,
+                          databaseId,
+                          listenerId));
+                } else {
+                  sendOnSnapshotError(appName, databaseId, listenerId, task.getException());
+                }
+              });
+    } catch (java.util.concurrent.RejectedExecutionException e) {
+      // Snapshot arrived after module invalidation shut down the executor.
+      // Safe to drop — the module is being torn down and no JS listener remains.
+    }
   }
 
   private void sendOnSnapshotError(