o Nh @sfddlmZmZmZddlmZddlmZmZm Z m Z m Z m Z ddl mZdgZGdddeZdS))ExecutorFutureThreadPoolExecutor) TracebackType)AnyCallableDictOptionalTupleType) EventEmitterExecutorEventEmitterc seZdZdZddeeffdd Zdedee dfd e e e ffd d Z dd e ddfddZdddZdeedededee fddZZS)r aAn event emitter class which runs handlers in a `concurrent.futures` executor. By default, this class creates a default `ThreadPoolExecutor`, but a custom executor may also be passed in explicitly to, for instance, use a `ProcessPoolExecutor` instead. This class runs all emitted events on the configured executor. Errors captured by the resulting Future are automatically emitted on the `error` event. This is unlike the EventEmitter, which have no error handling. The underlying executor may be shut down by calling the `shutdown` method. Alternately you can treat the event emitter as a context manager: ```py with ExecutorEventEmitter() as ee: # Underlying executor open @ee.on('data') def handler(data): print(data) ee.emit('event') # Underlying executor closed ``` Since the function call is scheduled on an executor, emit is always non-blocking. No effort is made to ensure thread safety, beyond using an executor. Nexecutorcs(tt||r||_dSt|_dSN)superr __init__ _executorr)selfr __class__J/home/air/yokohama/back/venv/lib/python3.10/site-packages/pyee/executor.pyr/s  zExecutorEventEmitter.__init__fargs.kwargscs:jj|g|Ri|}|jdtddffdd }dS)Nrreturncs2|}t|trd|dS|dur|dS)Nerror) exception isinstance Exceptionemit)rexcrrr _callback>s  z1ExecutorEventEmitter._emit_run.._callback)rsubmitadd_done_callbackr)rrrrfuturer#rr"r _emit_run6szExecutorEventEmitter._emit_runTwaitrcCs|jj|ddS)z)Call `shutdown` on the internal executor.)r(N)rshutdown)rr(rrrr)FszExecutorEventEmitter.shutdowncCs|Srrr"rrr __enter__KszExecutorEventEmitter.__enter__typevalue tracebackcCs |dSr)r))rr+r,r-rrr__exit__Ns zExecutorEventEmitter.__exit__r)T)rr )__name__ __module__ __qualname____doc__r rrrr rrstrr'boolr)r*r rrr. __classcell__rrrrr s*"    N)concurrent.futuresrrrtypesrtypingrrrr r r pyee.baser __all__r rrrrs