mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

Move writer.close() after writer_coro is done

pull/8/head
Nicolas Jouanin 2015-08-11 22:15:02 +02:00
rodzic 92a2b50a8c
commit 1e563ee257
1 zmienionych plików z 1 dodań i 1 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

2
hbmqtt/mqtt/protocol/handler.py
Wyświetl plik

@ -127,8 +127,8 @@ class ProtocolHandler:
def stop(self): def stop(self):
self._running = False self._running = False
yield from self.outgoing_queue.put("STOP") 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 asyncio.wait([self._writer_task, self._reader_task], loop=self._loop)
yield from self.writer.close()
# Stop incoming messages flow waiter # Stop incoming messages flow waiter
for packet_id in self.session.incoming_msg: for packet_id in self.session.incoming_msg:
self.session.incoming_msg[packet_id].cancel() self.session.incoming_msg[packet_id].cancel()