add some more error handling to hopefully prevent flaking change stre…

…am tests
Automattic · Aug 21, 2024 · a725a75 · a725a75
1 parent 8c6bb8b
commit a725a75
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/test/model.test.js b/test/model.test.js
@@ -3509,6 +3509,9 @@ describe('Model', function() {
           }
           changeStream.removeListener('change', listener);
           listener = null;
+          // Change stream may still emit "MongoAPIError: ChangeStream is closed" because change stream
+          // may still poll after close.
+          changeStream.on('error', () => {});
           changeStream.close();
           changeStream = null;
         });
@@ -3658,6 +3661,9 @@ describe('Model', function() {
           assert.equal(changeData.operationType, 'insert');
           assert.equal(changeData.fullDocument.name, 'Ned Stark');
 
+          // Change stream may still emit "MongoAPIError: ChangeStream is closed" because change stream
+          // may still poll after close.
+          changeStream.on('error', () => {});
           await changeStream.close();
           await db.close();
         });