stop read loop on shutdown

smira · May 19, 2016 · 950b0df · 950b0df
1 parent 0aa27ad
commit 950b0df
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/txzmq/connection.py b/txzmq/connection.py
@@ -206,6 +206,8 @@ def shutdown(self):
         if self.read_scheduled is not None:
             self.read_scheduled.cancel()
             self.read_scheduled = None
+        if self._read_loop is not None:
+            self._read_loop.stop()
 
     def __repr__(self):
         return "%s(%r, %r)" % (