From 25ec7dd5335e71bc7a72102bc9c5378b6686ee0e Mon Sep 17 00:00:00 2001 From: Matteo Collina Date: Mon, 7 Aug 2017 09:55:23 +0200 Subject: [PATCH] Revert "parallelize topic sub/unsub handles" This reverts commit e5d9c8af59c8689893de77acd077738132f021a3. --- lib/handlers/subscribe.js | 2 +- lib/handlers/unsubscribe.js | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/handlers/subscribe.js b/lib/handlers/subscribe.js index e0848805..86d24b5c 100644 --- a/lib/handlers/subscribe.js +++ b/lib/handlers/subscribe.js @@ -23,7 +23,7 @@ function handleSubscribe (client, packet, done) { var subs = packet.subscriptions var granted = [] - broker._parallel( + broker._series( new SubscribeState(client, packet, done, granted), doSubscribe, subs, diff --git a/lib/handlers/unsubscribe.js b/lib/handlers/unsubscribe.js index 8b4700a8..620b5256 100644 --- a/lib/handlers/unsubscribe.js +++ b/lib/handlers/unsubscribe.js @@ -37,7 +37,7 @@ function handleUnsubscribe (client, packet, done) { function actualUnsubscribe (client, packet, done) { var broker = client.broker - broker._parallel( + broker._series( new UnsubscribeState(client, packet, done, null), doUnsubscribe, packet.unsubscriptions,