U #i @svddlmZddlZddlZddlmZmZmZmZm Z ddl m Z erTddl m Z Gddde ZGdd d ZdS) ) annotationsN) TYPE_CHECKINGAnyDictList NamedTuple)Callback)Socketc@s"eZdZUdZded<ded<dS)CallbackListenerz#A tuple with `event` and `callback`streventrcallbackN)__name__ __module__ __qualname____doc____annotations__rr4/tmp/pip-unpacked-wheel-935k1slo/realtime/channel.pyr s r c@sfeZdZdZifdddddddZdd d d Zdd d d ZddddddZdddddZdS)Channela7 `Channel` is an abstraction for a topic listener for an existing socket connection. Each Channel has its own topic and a list of event-callbacks that responds to messages. Should only be instantiated through `connection.Socket().set_channel(topic)` Topic-Channel has a 1-many relationship. r r zDict[str, Any]None)sockettopicparamsreturncCs"||_||_||_g|_d|_dS)z :param socket: Socket object :param topic: Topic that it subscribes to on the realtime server :param params: FN)rrr listenersZjoined)selfrrrrrr__init__s zChannel.__init__)rcCst}|||S)z Wrapper for async def _join() to expose a non-async interface Essentially gets the only event loop and attempt joining a topic :return: Channel )asyncioZget_event_loopZrun_until_complete_join)rZlooprrrjoin(sz Channel.joinc sjt|jdidd}z|jjt|IdHWn4tk rd}ztt |WYdSd}~XYnXdS)zs Coroutine that attempts to join Phoenix Realtime server via a certain topic :return: None Zphx_joinN)rr payloadref) dictrrZ ws_connectionsendjsondumps Exceptionprintr )rZjoin_reqerrrr2s  z Channel._joinr)r r rcCst||d}|j||S)z :param event: A specific event will have a specific callback :param callback: Callback that takes msg payload as its first argument :return: Channel )r r )r rappend)rr r Zclrrron?s  z Channel.on)r rcsfdd|jD|_dS)zX :param event: Stop responding to a certain event :return: None csg|]}|jkr|qSrr ).0r r,rr Ns zChannel.off..N)r)rr rr,roffIs z Channel.offN) rrrrrr rr+r/rrrrrs     r) __future__rrr%typingrrrrrZrealtime.typesrZrealtime.connectionr r rrrrrs