diff --git a/packages/ddp-client/server/stream_client_nodejs.js b/packages/ddp-client/server/stream_client_nodejs.js
index 460fe9ff3b..719ff77911 100644
--- a/packages/ddp-client/server/stream_client_nodejs.js
+++ b/packages/ddp-client/server/stream_client_nodejs.js
@@ -171,13 +171,13 @@ export default class ClientStream extends StreamClientCommon {
       }, 'stream connect callback')
     );
 
-    var clientOnIfCurrent = (event, description, f) => {
+    var clientOnIfCurrent = (event, description, callback) => {
       this.client.on(
         event,
         Meteor.bindEnvironment((...args) => {
           // Ignore events from any connection we've already cleaned up.
           if (client !== this.client) return;
-          f.apply(this, args);
+          callback(...args);
         }, description)
       );
     };