From 7d409a3582eeac8bdfdbd6b2d3890426ddaf1850 Mon Sep 17 00:00:00 2001 From: Mohammad Kermani Date: Tue, 7 May 2024 10:54:57 +0000 Subject: [PATCH] test(scaling-pubsub): add message handler in node --- tests/scaling-pubsub/src/node/node.ts | 2 ++ 1 file changed, 2 insertions(+) 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)`,