- fix TODO[fibers] - not needed anymore

This commit is contained in:
denihs
2023-02-14 10:23:30 -04:00
parent 8b42cb381a
commit 0b473ff01a

View File

@@ -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;