No need to close stream when client has disconnected (it is already c…

…losed). Fixes issue #19
njouanin · Feb 5, 2016 · 5458ec7 · 5458ec7
1 parent de7634b
commit 5458ec7
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/hbmqtt/broker.py b/hbmqtt/broker.py
@@ -424,7 +424,6 @@ def client_connected(self, listener_name, reader: ReaderAdapter, writer: WriterA
                     yield from self._stop_handler(handler)
                     client_session.transitions.disconnect()
                     yield from self.plugins_manager.fire_event(EVENT_BROKER_CLIENT_DISCONNECTED, client_id=client_session.client_id)
-                    yield from writer.close()
                     connected = False
                 if unsubscribe_waiter in done:
                     self.logger.debug("%s handling unsubscription" % client_session.client_id)