diff --git a/packages/mongo/mongo_driver.js b/packages/mongo/mongo_driver.js index dbb173b9f36..da510077207 100644 --- a/packages/mongo/mongo_driver.js +++ b/packages/mongo/mongo_driver.js @@ -1094,8 +1094,8 @@ MongoConnection.prototype._observeChanges = function ( multiplexer = new ObserveMultiplexer({ ordered: ordered, onStop: function () { - observeDriver.stop(); delete self._observeMultiplexers[observeKey]; + observeDriver.stop(); } }); self._observeMultiplexers[observeKey] = multiplexer;