only check _pause if socket type is pull

JustinTulloss · Mar 17, 2015 · 19a0b81 · 19a0b81
1 parent 5d0aa8d
commit 19a0b81
Showing 1 changed file with 13 additions and 3 deletions.
diff --git a/lib/index.js b/lib/index.js
@@ -188,9 +188,8 @@ exports.Socket = function (type) {
   EventEmitter.call(this);
   this.type = type;
   this._zmq = new zmq.SocketBinding(defaultContext(), types[type]);
-  this._pause = false;
-  this._zmq.onReady = function() {
-    if (self._pause) return;
+
+  function onReady() {
     try {
       self._flush();
     } catch (err) {
@@ -201,6 +200,17 @@ exports.Socket = function (type) {
     }
   }
 
+  if (this.type == 'pull') {
+    this._pause = false;
+    this._zmq.onReady = function() {
+      if(self._pause) return;
+      onReady();
+    }
+  }
+  else {
+    this._zmq.onReady = onReady;
+  }
+
   this._outgoing = [];
 };