o fAh:!@sddlmZddlmZddlmZmZmZmZm Z m Z m Z m Z m Z mZmZeZGdddeZGdddeZeded ZGd d d Zd S) ) OrderedDict)Lock) AnyCallableDictListMappingOptionaloverloadSetTupleTypeVarUnionc@eZdZdZdS) PyeeExceptionz@An exception internal to pyee. Deprecated in favor of PyeeError.N__name__ __module__ __qualname____doc__rrR/var/www/html/brandlife/copilot/chat-env/lib/python3.10/site-packages/pyee/base.pyrrc@r) PyeeErrorzAn error internal to pyee.NrrrrrrrrHandler)boundc @sZeZdZdZdeddfddZdedeeeffddZ ded eeefddfd d Z e ded ede e ge ffd dZe ded ede de fddZ d2ded edee dee e e ge fffddZded ede e ge ffddZded ede de fddZded ede de fddZdede deedfdeeefddf ddZdedeefdd Zded ed!eddfd"d#Zded edeedfdeeefdef d$d%Zded edededef d&d'Z d2ded edee de fd(d)Zded ede ddfd*d+Zded ede ddfd,d-Zd2ded eeddfd.d/Z ded ede!e fd0d1Z"dS)3 EventEmitteraThe base event emitter class. All other event emitters inherit from this class. Most events are registered with an emitter via the `on` and `once` methods, and fired with the `emit` method. However, pyee event emitters have two *special* events: - `new_listener`: Fires whenever a new listener is created. Listeners for this event do not fire upon their own creation. - `error`: When emitted raises an Exception by default, behavior can be overridden by attaching callback to the event. For example: ```py @ee.on('error') def on_error(message): logging.err(message) ee.emit('error', Exception('something blew up')) ``` All callbacks are handled in a synchronous, blocking manner. As in node.js, raised exceptions are not automatically handled for you---you must catch your own exceptions, and treat them accordingly. selfreturnNcCst|_t|_dSN)dict_eventsr_lockrrrr__init__>s zEventEmitter.__init__cCs|j}|d=|S)Nr")__dict__copyrstaterrr __getstate__Es zEventEmitter.__getstate__r(cCs|j|t|_dSr)r%updaterr"r'rrr __setstate__Js  zEventEmitter.__setstate__eventcCdSrrrr,rrronNzEventEmitter.onfcCr-rrrr,r1rrrr/Pr0cCs|dur ||S|||S)auRegisters the function `f` to the event name `event`, if provided. If `f` isn't provided, this method calls `EventEmitter#listens_to`, and otherwise calls `EventEmitter#add_listener`. In other words, you may either use it as a decorator: ```py @ee.on('data') def data_handler(data): print(data) ``` Or directly: ```py ee.on('data', data_handler) ``` In both the decorated and undecorated forms, the event handler is returned. The upshot of this is that you can call decorated handlers directly, as well as use them in remove_listener calls. Note that this method's return type is a union type. If you are using mypy or pyright, you will probably want to use either `EventEmitter#listens_to` or `EventEmitter#add_listener`. N) listens_to add_listenerr2rrrr/Ss  csdtdtffdd }|S)aVReturns a decorator which will register the decorated function to the event name `event`: ```py @ee.listens_to("event") def data_handler(data): print(data) ``` By only supporting the decorator use case, this method has improved type safety over `EventEmitter#on`. r1rcs|||Sr_add_event_handlerr1r,rrrr/sz#EventEmitter.listens_to..onN)r)rr,r/rr8rr3uszEventEmitter.listens_tocCs|||||S)a:Register the function `f` to the event name `event`: ``` def data_handler(data): print(data) h = ee.add_listener("event", data_handler) ``` By not supporting the decorator use case, this method has improved type safety over `EventEmitter#on`. Nr5r2rrrr4s zEventEmitter.add_listenerkvcCs^|d|||j||jvrt|j|<||j||<WddS1s(wYdS)NZ new_listener)emitr"r!r)rr,r9r:rrrr6s   "zEventEmitter._add_event_handlerargs.kwargscCs||i|dSrr)rr1r<r=rrr _emit_runszEventEmitter._emit_runcCst|jS)z6Get a set of events that this emitter is listening to.N)setr!keysr#rrr event_namesszEventEmitter.event_nameserrorcCs(|dkrt|tr |td|dS)NrBz%Uncaught, unspecified 'error' event: ) isinstance Exceptionr)rr,rBrrr_emit_handle_potential_errors  z)EventEmitter._emit_handle_potential_errorcCsbd}|jt|j|t}Wdn1swY|D] }||||d}q#|S)NFT)r"listr!getrvaluesr>)rr,r<r=handledfuncsr1rrr_call_handlersszEventEmitter._call_handlerscOs.||||}|s|||r|dnd|S)acEmit `event`, passing `*args` and `**kwargs` to each attached function. Returns `True` if any functions are attached to `event`; otherwise returns `False`. Example: ```py ee.emit('data', '00101001') ``` Assuming `data` is an attached function, this will call `data('00101001')'`. rN)rKrE)rr,r<r=rIrrrr;szEventEmitter.emitcs,dtdtffdd }|dur|S||S)zkThe same as `ee.on`, except that the listener is automatically removed after being called. r1rcs0dtdtdtffdd }|S)Nr<r=rcslj$jvrjvrn WddSWdn1s*wY|i|Sr)r"r!_remove_listener)r<r=)r,r1rrrgs z.EventEmitter.once.._wrapper..g)rr6)r1rMr8r7r_wrappersz#EventEmitter.once.._wrapperN)r)rr,r1rNrr8ronces zEventEmitter.oncecCs.|j||t|j|s|j|=dSdS)zNaked unprotected removal.N)r!poplenr2rrrrLs zEventEmitter._remove_listenercCs8|j|||WddS1swYdS)z&Removes the function `f` from `event`.N)r"rLr2rrrremove_listener s"zEventEmitter.remove_listenercCsZ|j |durt|j|<n t|_WddSWddS1s&wYdS)ztRemove all listeners attached to `event`. If `event` is `None`, remove all listeners on all events. N)r"rr!r r.rrrremove_all_listenerss "z!EventEmitter.remove_all_listenerscCst|j|tS)z:Returns a list of all listeners registered to the `event`.N)rFr!rGrr@r.rrr listenersszEventEmitter.listenersr)#rrrrSelfr$rstrrr)r+r rrr/r rr3r4r6r rr>r rArEboolrKr;rOrLrRrSrrTrrrrr!s" "         ! rN) collectionsr threadingrtypingrrrrrr r r r r rrUrDrrrrrrrrs  4