From 062b475134c69f6878e8348a5fd37328bbc32311 Mon Sep 17 00:00:00 2001 From: David Glasser Date: Thu, 24 Oct 2013 20:09:21 -0700 Subject: [PATCH] don't die --- packages/mongo-livedata/oplog.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/mongo-livedata/oplog.js b/packages/mongo-livedata/oplog.js index 4ac5e5a46c..01b34e520c 100644 --- a/packages/mongo-livedata/oplog.js +++ b/packages/mongo-livedata/oplog.js @@ -207,7 +207,7 @@ MongoConnection.prototype._observeChangesWithOplog = function ( // This write cannot complete until we've caught up to "this point" in the // oplog, and then made it back to the steady state. self._oplogHandle.callWhenProcessedLatest(function () { - if (phase === PHASE.STEADY) + if (stopped || phase === PHASE.STEADY) write.committed(); else writesToCommitWhenWeReachSteady.push(write);