diff --git a/src/pubsub.js b/src/pubsub.js index 5c6e6505..297a54b7 100644 --- a/src/pubsub.js +++ b/src/pubsub.js @@ -143,8 +143,8 @@ module.exports = (node, Pubsub) => { return pubsub.setMaxListeners(n) }, - start: (cb) => pubsub.start(cb), + start: promisify((cb) => pubsub.start(cb)), - stop: (cb) => pubsub.stop(cb) + stop: promisify((cb) => pubsub.stop(cb)) } }