diff --git a/lib/cursor/changeStream.js b/lib/cursor/changeStream.js index 64fcbf22ab9..ec5cac5705f 100644 --- a/lib/cursor/changeStream.js +++ b/lib/cursor/changeStream.js @@ -141,8 +141,9 @@ class ChangeStream extends EventEmitter { close() { this.closed = true; if (this.driverChangeStream) { - this.driverChangeStream.close(); + return this.driverChangeStream.close(); } + return Promise.resolve(); } }