diff --git a/packages/minimongo/minimongo.js b/packages/minimongo/minimongo.js index e24dc31366..b3c3b34c39 100644 --- a/packages/minimongo/minimongo.js +++ b/packages/minimongo/minimongo.js @@ -373,6 +373,7 @@ LocalCollection.Cursor.prototype._depend = function (changers) { options[fnName] = notifyChange; }); + // observeChanges will stop() when this computation is invalidated self.observeChanges(options); } }; diff --git a/packages/minimongo/minimongo_tests.js b/packages/minimongo/minimongo_tests.js index c106713647..932c59000b 100644 --- a/packages/minimongo/minimongo_tests.js +++ b/packages/minimongo/minimongo_tests.js @@ -1774,7 +1774,9 @@ Tinytest.add("minimongo - reactive stop", function (test) { // observe callbacks don't wait for flush, they are inline. coll.insert({_id: 'F'}); test.equal(x, "FEDCBA"); + test.equal(y, "FEDCBA"); Deps.flush(); coll.insert({_id: 'G'}); test.equal(x, "FEDCBA"); + test.equal(y, "FEDCBA"); });