o Nh @sddlmZmZmZmZmZddlmZmZddl m Z ddl m Z m Z zddlmZWn ey7dZYnwdgZGddde ZdS) )AnyCallableDictOptionalTuple)DeferredensureDeferred)Failure) EventEmitter PyeeException) iscoroutineNTwistedEventEmittercsdeZdZdZfddZdedeedfdee efdd fd d Z d e d edd ffdd Z Z S)r aAn 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. cstt|dS)N)superr __init__self __class__I/home/air/yokohama/back/venv/lib/python3.10/site-packages/pyee/twisted.pyr7szTwistedEventEmitter.__init__fargs.kwargsreturnNcsd}z ||i|}WntydtYdSwtr(t|r(t|}n t|tr0|}n|s4dSdtddffdd }||dS)Nfailurercs|r d|dSdS)Nr)emit)rrrrerrbackMsz.TwistedEventEmitter._emit_run..errback) Exceptionrr r r isinstancer addErrback)rrrrdresultrrrr _emit_run:s    zTwistedEventEmitter._emit_runeventerrorc s|dkrDt|tr*z|WdSty)}z |d|WYd}~dSd}~wwt|tr7|d|dS|dtd|dStt|||dS)Nrr$zUnexpected failure object: ) rr raiseExceptionrrr rr _emit_handle_potential_error)rr#r$excrrrr&Ss   z0TwistedEventEmitter._emit_handle_potential_error) __name__ __module__ __qualname____doc__rrrrrstrr"r& __classcell__rrrrr s #   ")typingrrrrrtwisted.internet.deferrrtwisted.python.failurer pyee.baser r asyncior ImportError__all__r rrrrs