diff --git a/packages/minimongo/cursor.js b/packages/minimongo/cursor.js index 4db04d9734..3192797985 100644 --- a/packages/minimongo/cursor.js +++ b/packages/minimongo/cursor.js @@ -373,6 +373,13 @@ export default class Cursor { return handle; } + observeChangesAsync(options) { + return new Promise((resolve) => { + const handle = this.observeChanges(options); + handle.isReadyPromise.then(() => resolve(handle)); + }); + } + // XXX Maybe we need a version of observe that just calls a callback if // anything changed. _depend(changers, _allow_unordered) { diff --git a/packages/mongo/mongo_driver.js b/packages/mongo/mongo_driver.js index 5abb327e6e..3037e07b6b 100644 --- a/packages/mongo/mongo_driver.js +++ b/packages/mongo/mongo_driver.js @@ -966,8 +966,7 @@ Cursor.prototype.observeChanges = function (callbacks, options = {}) { }; Cursor.prototype.observeChangesAsync = async function (callbacks, options = {}) { - var self = this; - return self.observeChanges(callbacks, options); + return this.observeChanges(callbacks, options); }; MongoConnection.prototype._createSynchronousCursor = function(