Workaround for race condition

kakahuynh89 · Jun 20, 2011 · 191d68d · 191d68d
1 parent b0147f3
commit 191d68d
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/lib/transport.js b/lib/transport.js
@@ -521,12 +521,10 @@ Transport.prototype.subscribe = function () {
  */
 
 Transport.prototype.unsubscribe = function () {
-  if (this.subscribed) {
-    this.log.info('unsubscribing', this.id);
+  this.log.info('unsubscribing', this.id);
 
-    this.store.client(this.id).pause();
-    this.subscribed = false;
-  }
+  this.store.client(this.id).pause();
+  this.subscribed = false;
 };
 
 /**