diff --git a/mitogen/core.py b/mitogen/core.py
index f58eac83..30d2c911 100644
--- a/mitogen/core.py
+++ b/mitogen/core.py
@@ -805,11 +805,11 @@ class BasicStream(object):
 
     def on_disconnect(self, broker):
         LOG.debug('%r.on_disconnect()', self)
-        broker.stop_receive(self)
-        broker._stop_transmit(self)
         if self.receive_side:
+            broker.stop_receive(self)
             self.receive_side.close()
         if self.transmit_side:
+            broker._stop_transmit(self)
             self.transmit_side.close()
         fire(self, 'disconnect')