From e0ecf93c4dafa62b38c43f8c3a25ada4f6b86541 Mon Sep 17 00:00:00 2001 From: Alexander Duryagin Date: Thu, 19 May 2016 21:17:00 +0300 Subject: [PATCH] bugfix - read_loop should be a CooperativeTask, not Deferred --- txzmq/connection.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/txzmq/connection.py b/txzmq/connection.py index cf238b3..3de8301 100644 --- a/txzmq/connection.py +++ b/txzmq/connection.py @@ -267,9 +267,8 @@ def doRead(self): self.read_scheduled.cancel() self.read_scheduled = None if self._read_loop is None: - self._read_loop = task.cooperate(self._read_messages()).\ - whenDone().\ - addBoth(self._read_done) + self._read_loop = task.cooperate(self._read_messages()) + self._read_loop.whenDone().addBoth(self._read_done) def _read_messages(self): while True: