From 950b0df9efd581f448ef6f21c30e59e4f3c5e74a Mon Sep 17 00:00:00 2001 From: Alexander Duryagin Date: Thu, 19 May 2016 20:44:28 +0300 Subject: [PATCH] stop read loop on shutdown --- txzmq/connection.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/txzmq/connection.py b/txzmq/connection.py index 93e480c..cf238b3 100644 --- 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)" % (