o %h @svddlmZddlmZmZmZmZmZmZddl m Z m Z ddl m Z ddlmZmZeZdgZGdddeZdS) ) iscoroutine)AnyCallablecastDictOptionalTuple)DeferredensureDeferred)Failure) EventEmitter PyeeErrorTwistedEventEmitterc sveZdZdZdeddffdd Zdededeed fd e e efddf d d Z ded e deddffdd Z Z S)raAn event emitter class which can run twisted coroutines and handle returned Deferreds, in addition to synchronous blocking functions. For example: ```py @ee.on('event') @inlineCallbacks def async_handler(*args, **kwargs): yield returns_a_deferred() ``` or: ```py @ee.on('event') async def async_handler(*args, **kwargs): await returns_a_deferred() ``` When async handlers fail, Failures are first emitted on the `failure` event. If there are no `failure` handlers, the Failure's associated exception is then emitted on the `error` event. If there are no `error` handlers, the exception is raised. For consistency, when handlers raise errors synchronously, they're captured, wrapped in a Failure and treated as an async failure. This is unlike the behavior of EventEmitter, which have no special error handling. For twisted coroutine event handlers, calling emit is non-blocking. In other words, you do not have to await any results from emit, and the coroutine is scheduled in a fire-and-forget fashion. Similar behavior occurs for "sync" functions which return Deferreds. selfreturnNcstt|dS)N)superr__init__r __class__@/var/www/html/myenv/lib/python3.10/site-packages/pyee/twisted.pyr5szTwistedEventEmitter.__init__fargs.kwargscsd}z ||i|}WntydtYdSwt|r&t|}n t|tr.|}n|s2dSdtddffdd }||dS)Nfailurercs|r d|dSdS)Nr)emit)rrrrerrbackKsz.TwistedEventEmitter._emit_run..errback) Exceptionrr rr isinstancer addErrback)rrrrdresultrrrr _emit_run8s   zTwistedEventEmitter._emit_runeventerrorc s|dkrDt|tr*z|WdSty)}z |d|WYd}~dSd}~wwt|tr7|d|dS|dtd|dStttt | ||dS)Nrr%zUnexpected failure object: ) rr raiseExceptionrrr rrrr_emit_handle_potential_error)rr$r%excrrrr'Qs  z0TwistedEventEmitter._emit_handle_potential_error)__name__ __module__ __qualname____doc__Selfrrrrrstrr#r' __classcell__rrrrrs#   &N)asynciortypingrrrrrrtwisted.internet.deferr r twisted.python.failurer pyee.baser r r-__all__rrrrrs