Parallelize unsubscribe handler (#317)

lib/handlers/unsubscribe.js

@@ -3,11 +3,10 @@
 var write = require('../write')
 var validateTopic = require('./validations').validateTopic
 
-function UnsubscribeState (client, packet, finish, granted) {
+function UnsubscribeState (client, packet, finish) {
   this.client = client
   this.packet = packet
   this.finish = finish
-  this.granted = granted
 }
 
 function handleUnsubscribe (client, packet, done) {
@@ -37,8 +36,8 @@ function handleUnsubscribe (client, packet, done) {
 
 function actualUnsubscribe (client, packet, done) {
   var broker = client.broker
-  broker._series(
-    new UnsubscribeState(client, packet, done, null),
+  broker._parallel(
+    new UnsubscribeState(client, packet, done),
     doUnsubscribe,
     packet.unsubscriptions,
     completeUnsubscribe)
@@ -47,8 +46,10 @@ function actualUnsubscribe (client, packet, done) {
 function doUnsubscribe (sub, done) {
   var client = this.client
   var broker = client.broker
-  if (client.subscriptions[sub]) {
-    var func = client.subscriptions[sub].func
+  var s = client.subscriptions[sub]
+
+  if (s) {
+    var func = s.func
     delete client.subscriptions[sub]
     broker.unsubscribe(
       sub,
@@ -60,15 +61,16 @@ function doUnsubscribe (sub, done) {
 }
 
 function completeUnsubscribe (err) {
-  var packet = this.packet
   var client = this.client
-  var done = this.finish
 
   if (err) {
     client.emit('error', err)
     return
   }
 
+  var packet = this.packet
+  var done = this.finish
+
   if ((!packet.close || client.clean === true) && packet.unsubscriptions.length > 0) {
     client.broker.emit('unsubscribe', packet.unsubscriptions, client)
   }