diff --git a/src/pubsub.js b/src/pubsub.js index b3d9263795..525cb9a566 100644 --- a/src/pubsub.js +++ b/src/pubsub.js @@ -26,7 +26,7 @@ module.exports = (node) => { floodSub.subscribe(topic) } - floodSub.pubsub.on(topic, handler) + floodSub.on(topic, handler) setImmediate(cb) }