make sure we stop the recv stream

circus-tent · Oct 24, 2013 · 4d07130 · 4d07130
1 parent db3205f
commit 4d07130
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/circus/client.py b/circus/client.py
@@ -45,6 +45,7 @@ def _init_context(self, context):
         self.context = context or zmq.Context.instance()
 
     def stop(self):
+        self.stream.stop_on_recv()
         self.socket.close()
 
     def send_message(self, command, **props):