From 2cc2be3d9cda293dcedfc85723f4762075b551d9 Mon Sep 17 00:00:00 2001 From: Shane Kilkelly Date: Fri, 11 Oct 2019 10:01:21 +0100 Subject: [PATCH] send messages to clients with concurrency of 2 --- services/real-time/app/coffee/WebsocketLoadBalancer.coffee | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/services/real-time/app/coffee/WebsocketLoadBalancer.coffee b/services/real-time/app/coffee/WebsocketLoadBalancer.coffee index ba69d79beb..12b7ef812b 100644 --- a/services/real-time/app/coffee/WebsocketLoadBalancer.coffee +++ b/services/real-time/app/coffee/WebsocketLoadBalancer.coffee @@ -91,7 +91,8 @@ module.exports = WebsocketLoadBalancer = }, "distributing event to clients" seen = {} # Send the messages to clients async, don't wait for them all to finish - Async.eachSeries clientList + Async.eachLimit clientList + , 2 , (client, cb) -> Utils.getClientAttributes client, ['is_restricted_user'], (err, {is_restricted_user}) -> return cb(err) if err?