kopia lustrzana https://github.com/Yakifo/amqtt
Another asyncio fix to properly handle CancelledError as normal (and reraise) vs. exception
rodzic
1f5efd383f
commit
304c731831
|
@ -451,6 +451,8 @@ class ProtocolHandler:
|
|||
yield from self.plugins_manager.fire_event(EVENT_MQTT_PACKET_SENT, packet=packet, session=self.session)
|
||||
except (ConnectionResetError, BrokenPipeError):
|
||||
yield from self.handle_connection_closed()
|
||||
except asyncio.CancelledError:
|
||||
raise
|
||||
except BaseException as e:
|
||||
self.logger.warning("Unhandled exception: %s" % e)
|
||||
raise
|
||||
|
|
Ładowanie…
Reference in New Issue