listen for error events on change stream to avoid change stream tests…

… flaking
Automattic · Aug 21, 2024 · e0d5984 · e0d5984
1 parent 1b5fecc
commit e0d5984
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/test/model.watch.test.js b/test/model.watch.test.js
@@ -56,6 +56,9 @@ describe('model: watch: ', function() {
       assert.strictEqual(readyCalled, false);
 
       await close;
+      // Change stream may still emit "MongoAPIError: ChangeStream is closed" because change stream
+      // may still poll after close.
+      changeStream.on('error', () => {});
     });
 
     it('watch() close() closes the stream (gh-7022)', async function() {
@@ -75,6 +78,9 @@ describe('model: watch: ', function() {
 
       const closedData = await closed;
       assert.strictEqual(closedData, true);
+      // Change stream may still emit "MongoAPIError: ChangeStream is closed" because change stream
+      // may still poll after close.
+      changeStream.on('error', () => {});
     });
   });
 });