From 14efff200b772bf1d733519013573e459caf68d9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Nacho=20Codo=C3=B1er?= Date: Thu, 22 Feb 2024 15:59:54 +0100 Subject: [PATCH] implement observeChangesAsync on the client --- packages/minimongo/cursor.js | 7 +++++++ packages/mongo/mongo_driver.js | 3 +-- 2 files changed, 8 insertions(+), 2 deletions(-) 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(