github/meteor
1
1
Fork 0
mirror of https://github.com/meteor/meteor.git synced 2026-05-02 03:01:46 -04:00
Code Issues Packages Projects Releases Wiki Activity

- fix test: 'recursive observe throws, MONGO | STRING'

Browse Source
This commit is contained in:
denihs
2023-02-13 14:33:39 -04:00
parent be7dec0818
commit edc899df72
1 changed files with 27 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
packages/mongo/mongo_livedata_tests.js
View File

@@ -768,30 +768,36 @@ _.each( ['STRING', 'MONGO'], function(idGeneration) {
// This behavior isn't great, but it beats deadlock.
if (Meteor.isServer) {
Tinytest.addAsync("mongo-livedata - recursive observe throws, " + idGeneration, function (test, onComplete) {
var run = test.runId();
var coll = new Mongo.Collection("observeInCallback-"+run, collectionOptions);
Tinytest.addAsync(
'mongo-livedata - recursive observe throws, ' + idGeneration,
async function(test, onComplete) {
var run = test.runId();
var coll = new Mongo.Collection(
'observeInCallback-' + run,
collectionOptions
);
var callbackCalled = false;
var handle = coll.find({}).observe({
added: function (newDoc) {
callbackCalled = true;
test.throws(function () {
coll.find({}).observe();
});
}
});
test.isFalse(callbackCalled);
// Insert a document. Observe that the added callback is called.
runInFence(function () {
coll.insert({foo: 42});
});
test.isTrue(callbackCalled);
var callbackCalled = false;
var handle = await coll.find({}).observe({
added: async function(newDoc) {
callbackCalled = true;
await test.throwsAsync(async function() {
await coll.find({}).observe();
});
},
});
test.isFalse(callbackCalled);
// Insert a document. Observe that the added callback is called.
await runInFence(async function() {
await coll.insertAsync({ foo: 42 });
});
test.isTrue(callbackCalled);
handle.stop();
handle.stop();
onComplete();
});
onComplete();
}
);
Tinytest.addAsync("mongo-livedata - cursor dedup, " + idGeneration, function (test, onComplete) {
var run = test.runId();