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, {