From f8334b8a4220d2e2a5fd2c5be3ef385ea2bc05f9 Mon Sep 17 00:00:00 2001 From: denihs Date: Thu, 26 Jan 2023 14:38:25 -0400 Subject: [PATCH] - fix test `livedata stub - methods calling methods` --- packages/ddp-client/common/livedata_connection.js | 2 -- .../ddp-client/test/livedata_connection_tests.js | 13 +++++++------ 2 files changed, 7 insertions(+), 8 deletions(-) diff --git a/packages/ddp-client/common/livedata_connection.js b/packages/ddp-client/common/livedata_connection.js index 70aca6914e..5abf720630 100644 --- a/packages/ddp-client/common/livedata_connection.js +++ b/packages/ddp-client/common/livedata_connection.js @@ -1741,8 +1741,6 @@ export class Connection { } async onMessage(raw_msg) { - //TODO[fibers]: remove comment - console.log('onMessage', raw_msg); let msg; try { msg = DDPCommon.parseDDP(raw_msg); diff --git a/packages/ddp-client/test/livedata_connection_tests.js b/packages/ddp-client/test/livedata_connection_tests.js index 1fb3c3d640..c96fd4945f 100644 --- a/packages/ddp-client/test/livedata_connection_tests.js +++ b/packages/ddp-client/test/livedata_connection_tests.js @@ -678,18 +678,19 @@ if (Meteor.isClient) { // setup methods conn.methods({ - do_something: function() { - conn.call('do_something_else'); + do_something: async function() { + await conn.applyAsync('do_something_else', []); }, - do_something_else: function() { - coll.insertAsync({ a: 1 }); + do_something_else: async function() { + await coll.insertAsync({ a: 1 }); } }); const o = await observeCursor(test, coll.find()); - // call method. - conn.call('do_something', _.identity); + // we use the applyAsync() instead of callAsync() because we want to control when to "pause" + // or "continue" the method execution by using the methods stream.receive() + await conn.applyAsync('do_something', []); // see we only send message for outer methods const message = testGotMessage(test, stream, {