From 1e563ee2572abb55e5c3c708aec2e88e7e749417 Mon Sep 17 00:00:00 2001 From: Nicolas Jouanin Date: Tue, 11 Aug 2015 22:15:02 +0200 Subject: [PATCH] Move writer.close() after writer_coro is done --- hbmqtt/mqtt/protocol/handler.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hbmqtt/mqtt/protocol/handler.py b/hbmqtt/mqtt/protocol/handler.py index d63214b..208f358 100644 --- a/hbmqtt/mqtt/protocol/handler.py +++ b/hbmqtt/mqtt/protocol/handler.py @@ -127,8 +127,8 @@ class ProtocolHandler: def stop(self): self._running = False yield from self.outgoing_queue.put("STOP") - yield from self.writer.close() yield from asyncio.wait([self._writer_task, self._reader_task], loop=self._loop) + yield from self.writer.close() # Stop incoming messages flow waiter for packet_id in self.session.incoming_msg: self.session.incoming_msg[packet_id].cancel()