3 ñ\ð]0 ã@s<ddlZddlmZGdd„dejƒZGdd„dejƒZdS)éN)Ú namespacec@sfeZdZdZdd„Zdd„Zddd„Zdd d „Zdd d „Zdd d„Z ddd„Z ddd„Z ddd„Z dS)ÚAsyncNamespaceaRBase class for asyncio server-side class-based namespaces. A class-based namespace is a class that contains all the event handlers for a Socket.IO namespace. The event handlers are methods of the class with the prefix ``on_``, such as ``on_connect``, ``on_disconnect``, ``on_message``, ``on_json``, and so on. These can be regular functions or coroutines. :param namespace: The Socket.IO namespace to be used with all the event handlers defined in this class. If this argument is omitted, the default namespace is used. cCsdS)NT©)ÚselfrrúE/tmp/pip-build-mqc4i71p/python-socketio/socketio/asyncio_namespace.pyÚis_asyncio_basedszAsyncNamespace.is_asyncio_basedc Çsjd|}t||ƒrft||ƒ}tj|ƒdkrZy||ŽIdH}Wqbtjk rVd}YqbXn||Ž}|SdS)aŒDispatch an event to the proper handler method. In the most common usage, this method is not overloaded by subclasses, as it performs the routing of events to methods. However, this method can be overriden if special dispatching rules are needed, or if having a single method that catches all events is desired. Note: this method is a coroutine. Úon_TN)ÚhasattrÚgetattrÚasyncioÚiscoroutinefunctionÚCancelledError)rÚeventÚargsÚ handler_nameÚhandlerÚretrrrÚ trigger_events    zAsyncNamespace.trigger_eventNcÃs$|jj|||||p|j|dIdHS)a)Emit a custom event to one or more connected clients. The only difference with the :func:`socketio.Server.emit` method is that when the ``namespace`` argument is not given the namespace associated with the class is used. Note: this method is a coroutine. )ÚdataÚroomÚskip_sidrÚcallbackN)ÚserverÚemitr)rrrrrrrrrrr,s zAsyncNamespace.emitcÃs"|jj||||p|j|dIdHS)a$Send a message to one or more connected clients. The only difference with the :func:`socketio.Server.send` method is that when the ``namespace`` argument is not given the namespace associated with the class is used. Note: this method is a coroutine. )rrrrN)rÚsendr)rrrrrrrrrr;s zAsyncNamespace.sendcÃs|jj||p|jdIdHS)aClose a room. The only difference with the :func:`socketio.Server.close_room` method is that when the ``namespace`` argument is not given the namespace associated with the class is used. Note: this method is a coroutine. )rN)rÚ close_roomr)rrrrrrrIs zAsyncNamespace.close_roomcÃs|jj||p|jdIdHS)a Return the user session for a client. The only difference with the :func:`socketio.Server.get_session` method is that when the ``namespace`` argument is not given the namespace associated with the class is used. Note: this method is a coroutine. )rN)rÚ get_sessionr)rÚsidrrrrrUs zAsyncNamespace.get_sessioncÃs|jj|||p|jdIdHS)a Store the user session for a client. The only difference with the :func:`socketio.Server.save_session` method is that when the ``namespace`` argument is not given the namespace associated with the class is used. Note: this method is a coroutine. )rN)rÚ save_sessionr)rrÚsessionrrrrras zAsyncNamespace.save_sessioncCs|jj||p|jdS)a Return the user session for a client with context manager syntax. The only difference with the :func:`socketio.Server.session` method is that when the ``namespace`` argument is not given the namespace associated with the class is used. )r)rrr)rrrrrrrmszAsyncNamespace.sessioncÃs|jj||p|jdIdHS)aDisconnect a client. The only difference with the :func:`socketio.Server.disconnect` method is that when the ``namespace`` argument is not given the namespace associated with the class is used. Note: this method is a coroutine. )rN)rÚ disconnectr)rrrrrrr vs zAsyncNamespace.disconnect)NNNNN)NNNN)N)N)N)N)N) Ú__name__Ú __module__Ú __qualname__Ú__doc__rrrrrrrrr rrrrrs   rc@s<eZdZdZdd„Zdd„Zd dd„Zdd d „Zd d „ZdS)ÚAsyncClientNamespaceaRBase class for asyncio client-side class-based namespaces. A class-based namespace is a class that contains all the event handlers for a Socket.IO namespace. The event handlers are methods of the class with the prefix ``on_``, such as ``on_connect``, ``on_disconnect``, ``on_message``, ``on_json``, and so on. These can be regular functions or coroutines. :param namespace: The Socket.IO namespace to be used with all the event handlers defined in this class. If this argument is omitted, the default namespace is used. cCsdS)NTr)rrrrrsz%AsyncClientNamespace.is_asyncio_basedc Çsjd|}t||ƒrft||ƒ}tj|ƒdkrZy||ŽIdH}Wqbtjk rVd}YqbXn||Ž}|SdS)aŒDispatch an event to the proper handler method. In the most common usage, this method is not overloaded by subclasses, as it performs the routing of events to methods. However, this method can be overriden if special dispatching rules are needed, or if having a single method that catches all events is desired. Note: this method is a coroutine. rTN)r r r r r )rrrrrrrrrr“s    z"AsyncClientNamespace.trigger_eventNcÃs |jj|||p|j|dIdHS)aEmit a custom event to the server. The only difference with the :func:`socketio.Client.emit` method is that when the ``namespace`` argument is not given the namespace associated with the class is used. Note: this method is a coroutine. )rrrN)Úclientrr)rrrrrrrrr©s zAsyncClientNamespace.emitcÃs|jj||p|j|dIdHS)aSend a message to the server. The only difference with the :func:`socketio.Client.send` method is that when the ``namespace`` argument is not given the namespace associated with the class is used. Note: this method is a coroutine. )rrN)r&rr)rrrrrrrr¶s zAsyncClientNamespace.sendcÃs|jjƒIdHS)aDisconnect a client. The only difference with the :func:`socketio.Client.disconnect` method is that when the ``namespace`` argument is not given the namespace associated with the class is used. Note: this method is a coroutine. N)r&r )rrrrr Ãs zAsyncClientNamespace.disconnect)NNN)NN) r!r"r#r$rrrrr rrrrr%ƒs   r%)r ZsocketiorÚ NamespacerZClientNamespacer%rrrrÚs }