don't use zero-copy message tracker for blocking behavior

closes philipbergen#1
minrk · Sep 30, 2013 · 63efdd5 · 63efdd5
1 parent 7026b9d
commit 63efdd5
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/py/zero/__init__.py b/py/zero/__init__.py
@@ -437,9 +437,10 @@ def send(self, obj):
         self.setup.debug('Sending %s to %s', msg, self.setup.point)
         sleep(self.naptime)  # TODO: Find out how to tell when it is connected
         self.naptime = 0
-        tracker = self.sock.send(msg, copy=False, track=True)
-        if self.setup.block:
-            tracker.wait()
+        flags = 0
+        if not self.setup.block:
+            flags |= zmq.NOBLOCK
+        self.sock.send(msg, flags)
 
     @property
     def active(self):