From 29baab53750a8a417ff9b00c9b124d42315856f0 Mon Sep 17 00:00:00 2001 From: Jacopo Scazzosi Date: Tue, 22 Aug 2023 09:20:28 +0200 Subject: [PATCH] improved example usage in README.md --- README.md | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/README.md b/README.md index c24159b..3e642f1 100644 --- a/README.md +++ b/README.md @@ -56,21 +56,21 @@ const serverFactory: NodeFactory = (send, broadcast, opts) => { }; }; -relay.addNode('server', serverFactory, {}); +relay.addNode('server', serverFactory, { + concurrency: 2, + highWaterMark: 2, + throttle: queueLength => queueLength * 10, // When the internal queue grows above highWaterMark, + // delay responses by 10 times the length of the queue + // itself in milliseconds +}); const clientFactory: NodeFactory = (send, broadcast, opts) => { - let count = 0; - const loop = () => { + const now = Date.now(); send('server', { id: uid(), type: 'req' }).then(() => { - if (count < 10) { - count += 1; - loop() - } else { - count = 0; + console.log('client loop lag', Date.now() - now); setImmediate(loop); - } }); };