diff --git a/mitogen/core.py b/mitogen/core.py index e8b98ecb..e139cf60 100644 --- a/mitogen/core.py +++ b/mitogen/core.py @@ -619,8 +619,10 @@ class BasicStream(object): LOG.debug('%r.on_disconnect()', self) broker.stop_receive(self) broker.stop_transmit(self) - self.receive_side.close() - self.transmit_side.close() + if self.receive_side: + self.receive_side.close() + if self.transmit_side: + self.transmit_side.close() fire(self, 'disconnect') def on_shutdown(self, broker):