fire 'disconnected' callback from abort()

This commit is contained in:
Georg Lukas 2020-04-04 13:13:20 +02:00
parent ab9040c30e
commit 5be46a5e68

View file

@ -516,6 +516,7 @@ class XMLStream(asyncio.BaseProtocol):
self.event("killed") self.event("killed")
self.disconnected.set_result(True) self.disconnected.set_result(True)
self.disconnected = asyncio.Future() self.disconnected = asyncio.Future()
self.event("disconnected", self.disconnect_reason)
def reconnect(self, wait=2.0, reason="Reconnecting"): def reconnect(self, wait=2.0, reason="Reconnecting"):
"""Calls disconnect(), and once we are disconnected (after the timeout, or """Calls disconnect(), and once we are disconnected (after the timeout, or