googleapis
diff --git a/‎dev/src/reference.ts‎
Lines changed: 3 additions & 1 deletion b/‎dev/src/reference.ts‎
Lines changed: 3 additions & 1 deletion
diff --git a/‎dev/test/bulk-writer.ts‎
Lines changed: 2 additions & 2 deletions b/‎dev/test/bulk-writer.ts‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎dev/test/partition-query.ts‎
Lines changed: 2 additions & 2 deletions b/‎dev/test/partition-query.ts‎
Lines changed: 2 additions & 2 deletions
@@ -2285,7 +2285,9 @@ export class Query<T = firestore.DocumentData> implements firestore.Query<T> {
           if (proto.done) {
             logger('Query._stream', tag, 'Trigger Logical Termination.');
             backendStream.unpipe(stream);
-            stream.emit('end');
+            backendStream.resume();
+            backendStream.end();
+            stream.end();
           }
         } else {
           callback(undefined, {readTime});
 
@@ -188,8 +188,8 @@ describe('BulkWriter', () => {
     });
   }
 
-  afterEach(() => {
-    verifyInstance(firestore);
+  afterEach(async () => {
+    await verifyInstance(firestore);
     setTimeoutHandler(setTimeout);
   });
 
 
@@ -86,8 +86,8 @@ describe('Partition Query', () => {
     });
   });
 
-  afterEach(() => {
-    verifyInstance(firestore);
+  afterEach(async () => {
+    await verifyInstance(firestore);
     setTimeoutHandler(setTimeout);
   });
Original file line number	Diff line number	Diff line change
`@@ -188,8 +188,8 @@ describe('BulkWriter', () => {`
`188`	`188`	`});`
`189`	`189`	`}`
`190`	`190`
`191`		`- afterEach(() => {`
`192`		`- verifyInstance(firestore);`
	`191`	`+ afterEach(async () => {`
	`192`	`+ await verifyInstance(firestore);`
`193`	`193`	`setTimeoutHandler(setTimeout);`
`194`	`194`	`});`
`195`	`195`