From 0b473ff01ac4db53771206b09e14a6b6a5172556 Mon Sep 17 00:00:00 2001 From: denihs Date: Tue, 14 Feb 2023 10:23:30 -0400 Subject: [PATCH] - fix TODO[fibers] - not needed anymore --- packages/mongo/oplog_observe_driver.js | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/packages/mongo/oplog_observe_driver.js b/packages/mongo/oplog_observe_driver.js index 51a04b4aaf..95e8f23b8c 100644 --- a/packages/mongo/oplog_observe_driver.js +++ b/packages/mongo/oplog_observe_driver.js @@ -83,6 +83,7 @@ OplogObserveDriver = function (options) { Package['facts-base'] && Package['facts-base'].Facts.incrementServerFact( "mongo-livedata", "observe-drivers-oplog", 1); + self._registerPhaseChange(PHASE.QUERYING); self._matcher = options.matcher; // we are now using projection, not fields in the cursor description even if you pass {fields} @@ -830,10 +831,9 @@ _.extend(OplogObserveDriver.prototype, { if (self._stopped) return; - // TODO[fibers] not sure about this change. For now it doesn't seems to affect other parts - self._registerPhaseChange(PHASE.QUERYING); - // if (self._phase !== PHASE.QUERYING) - // throw Error("Phase unexpectedly " + self._phase); + + if (self._phase !== PHASE.QUERYING) + throw Error("Phase unexpectedly " + self._phase); if (self._requeryWhenDoneThisQuery) { self._requeryWhenDoneThisQuery = false;