diff --git a/tests/scaling-pubsub/src/node/node.ts b/tests/scaling-pubsub/src/node/node.ts index 6c7c2c7..482fb05 100644 --- a/tests/scaling-pubsub/src/node/node.ts +++ b/tests/scaling-pubsub/src/node/node.ts @@ -51,6 +51,8 @@ setTimeout(async () => { }, 10_000); }, 30_000); +node.handleIncomingMessage(async () => {}); + node.subscribe('rosenet-news', (message) => { console.info( `Message received: ${message} (delay: ${(Date.now() - +message) / 1000}s)`,