Closing the write and the watch stream when idle

Author: schmidt-sebastian

packages/firestore/src/api/database.ts

@@ -310,7 +310,7 @@ export class Firestore implements firestore.Firestore, FirebaseService {
       PlatformSupport.getPlatform(),
       databaseInfo,
       this._config.credentials,
-      new AsyncQueue()
+      this.initializeAsyncQueue()
     );
     return this._firestoreClient.start(persistence);
   }
@@ -455,6 +455,11 @@ export class Firestore implements firestore.Firestore, FirebaseService {
         );
     }
   }
+
+  /** Creates a new AsyncQueue. Can be overwritten to provide a custom queue. */
+  protected initializeAsyncQueue(): AsyncQueue {
+    return new AsyncQueue();
+  }
 }
 
 /**

packages/firestore/src/local/local_store.ts

@@ -582,9 +582,9 @@ export class LocalStore {
 
   /**
    * Gets the mutation batch after the passed in batchId in the mutation queue
-   *  or null if empty.
-   *  @param afterBatchId If provided, the batch to search after.
-   *  @returns The next mutation or null if there wasn't one.
+   * or null if empty.
+   * @param afterBatchId If provided, the batch to search after.
+   * @returns The next mutation or null if there wasn't one.
    */
   nextMutationBatch(afterBatchId?: BatchId): Promise<MutationBatch | null> {
     return this.persistence.runTransaction('Get next mutation batch', txn => {