[stream-refactor] fix crash in detach() / during async/multiple_items_loop.yml

5 years ago · 1d2bfc28da
parent 93abbcaf7a
commit 1d2bfc28da
1 changed files with 1 additions and 1 deletions
--- a/mitogen/core.py
+++ b/mitogen/core.py
@ -3418,7 +3418,7 @@ class ExternalContext(object):
            self.parent.send_await(Message(handle=DETACHING))
            LOG.info('Detaching from %r; parent is %s', stream, self.parent)
            for x in range(20):
-                pending = self.broker.defer_sync(lambda: stream.pending_bytes())
+                pending = self.broker.defer_sync(stream.protocol.pending_bytes)
                if not pending:
                    break
                time.sleep(0.05)