parallelize topic sub/unsub handles

moscajs · Jul 1, 2017 · e5d9c8a · e5d9c8a
1 parent 7e1fdeb
commit e5d9c8a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/lib/handlers/subscribe.js b/lib/handlers/subscribe.js
@@ -22,7 +22,7 @@ function handleSubscribe (client, packet, done) {
   var subs = packet.subscriptions
   var granted = []
 
-  broker._series(
+  broker._parallel(
     new SubscribeState(client, packet, done, granted),
     doSubscribe,
     subs,

diff --git a/lib/handlers/unsubscribe.js b/lib/handlers/unsubscribe.js
@@ -27,7 +27,7 @@ function handleUnsubscribe (client, packet, done) {
 
 function actualUnsubscribe (client, packet, done) {
   var broker = client.broker
-  broker._series(
+  broker._parallel(
     new UnsubscribeState(client, packet, done, null),
     doUnsubscribe,
     packet.unsubscriptions,