i8#@SSKrSSKJr SSKJrJrJr "SS5rg)N) AsyncClient) SocketIOError TimeoutErrorDisconnectedErrorc\rSrSrSr\rSr0SSSSS4Sjr\ S 5r \ S 5r SS jr SS jr SS jrSrSrSrSrg)AsyncSimpleClientaA Socket.IO client. This class implements a simple, yet fully compliant Socket.IO web client with support for websocket and long-polling transports. The positional and keyword arguments given in the constructor are passed to the underlying :func:`socketio.AsyncClient` object. cXlX lSUlSUl[R "5UlSUl[R "5Ul/Ul g)N/F) client_args client_kwargsclient namespaceasyncioEventconnected_event connected input_event input_buffer)selfargskwargss Y/home/admin/cozy_coffee/venv/lib/python3.13/site-packages/socketio/async_simple_client.py__init__AsyncSimpleClient.__init__sG# &}}"==?Nr z socket.ioc ^# TR(a [S5eUTl/TlTRR 5 TR "TR0TRD6Tl TRRTRS9U4Sj5nTRRTRS9U4Sj5n TRRTRS9U4Sj5n TRRSTRS9U4Sj5n TRRXX4U/UUS9IS hvN g N7f) apConnect to a Socket.IO server. :param url: The URL of the Socket.IO server. It can include custom query string parameters if required by the server. If a function is provided, the client will invoke it to obtain the URL each time a connection or reconnection is attempted. :param headers: A dictionary with custom headers to send with the connection request. If a function is provided, the client will invoke it to obtain the headers dictionary each time a connection or reconnection is attempted. :param auth: Authentication data passed to the server with the connection request, normally a dictionary with one or more string key/value pairs. If a function is provided, the client will invoke it to obtain the authentication data each time a connection or reconnection is attempted. :param transports: The list of allowed transports. Valid transports are ``'polling'`` and ``'websocket'``. If not given, the polling transport is connected first, then an upgrade to websocket is attempted. :param namespace: The namespace to connect to as a string. If not given, the default namespace ``/`` is used. :param socketio_path: The endpoint where the Socket.IO server is installed. The default value is appropriate for most cases. :param wait_timeout: How long the client should wait for the connection. The default is 5 seconds. Note: this method is a coroutine. zAlready connectedrcH>STlTRR5 g)NTrrsetrsrconnect*AsyncSimpleClient.connect..connectDs!DN  $ $ &rc:>TRR5 gN)rclearr#sr disconnect-AsyncSimpleClient.connect..disconnectIs  & & (rcH>STlTRR5 g)NFr!r#sr__disconnect_final5AsyncSimpleClient.connect..__disconnect_finalMs"DN  $ $ &r*cv>TRRU/UQ5 TRR5 gr')rappendrr")eventrrs ron_event+AsyncSimpleClient.connect..on_eventRs/    $ $e^d^ 4    "r)headersauth transports namespaces socketio_path wait_timeoutN) r RuntimeErrorrrrr( client_classr r rr1onr$) rurlr4r5r6rr8r9r$r)$_AsyncSimpleClient__disconnect_finalr2s ` rr$AsyncSimpleClient.connects?B >>23 3"  ''   5!%!3!35    T^^  4 ' 5 '   T^^  4 ) 5 )   T^^  4 ' 5 ' t~~ 6 # 7 #kk!! t!{-%"' ' 'sEE E E crUR(a%URRUR5$S$)zThe session ID received from the server. The session ID is not guaranteed to remain constant throughout the life of the connection, as reconnections can cause it to change. N)rget_sidrr#s rsidAsyncSimpleClient.sid\s(7;kkt{{""4>>2KtKrc\UR(aURR5$S$)zThe name of the transport currently in use. The transport is returned as a string and can be one of ``polling`` and ``websocket``. )r transportr#s rrFAsyncSimpleClient.transportes"+/++t{{$$&=2=rc # URR5IShvN UR(d [5eURR XUR S9IShvN $NLN![a Of=fM7f)aEmit an event to the server. :param event: The event name. It can be any string. The event names ``'connect'``, ``'message'`` and ``'disconnect'`` are reserved and should not be used. :param data: The data to send to the server. Data can be of type ``str``, ``bytes``, ``list`` or ``dict``. To send multiple arguments, use a tuple where each element is of one of the types indicated above. Note: this method is a coroutine. This method schedules the event to be sent out and returns, without actually waiting for its delivery. In cases where the client needs to ensure that the event was received, :func:`socketio.SimpleClient.call` should be used instead. Nr)rwaitrrremitrr)rr1datas rrJAsyncSimpleClient.emitns$&&++- - ->>')) ![[--e8<.HHH .H   sEBA.B'A2)A0*A2-B0A22 A?<B>A??Bc"# URR5IShvN UR(d [5eURR XUR US9IShvN $NMN![a e[a Of=fM7f)a{Emit an event to the server and wait for a response. This method issues an emit and waits for the server to provide a response or acknowledgement. If the response does not arrive before the timeout, then a ``TimeoutError`` exception is raised. :param event: The event name. It can be any string. The event names ``'connect'``, ``'message'`` and ``'disconnect'`` are reserved and should not be used. :param data: The data to send to the server. Data can be of type ``str``, ``bytes``, ``list`` or ``dict``. To send multiple arguments, use a tuple where each element is of one of the types indicated above. :param timeout: The waiting timeout. If the timeout is reached before the server acknowledges the event, then a ``TimeoutError`` exception is raised. Note: this method is a coroutine. N)rtimeout) rrIrrrcallrrr)rr1rKrNs rrOAsyncSimpleClient.calls(&&++- - ->>')) ![[--e8<6=.??? .?     sEBA/B(A3*A1+A3.B1A33B B B  BcZ# UR(d[R"URR 5US9IShvN UR (d [5e[R"URR 5US9IShvN URR5 UR(dMURRS5$N![R a [ 5ef=fNp![R a [ 5ef=f7f)aWait for an event from the server. :param timeout: The waiting timeout. If the timeout is reached before the server acknowledges the event, then a ``TimeoutError`` exception is raised. Note: this method is a coroutine. The return value is a list with the event name as the first element. If the server included arguments with the event, they are returned as additional list elements. )rNNr) rrwait_forrrIrrrrr(pop)rrNs rreceiveAsyncSimpleClient.receives## %&&t';';'@'@'B/6888>>')) %&&t'7'7'<'<'>/6888    " " $###  $$Q''8'' %"n$ % 8'' %"n$ %s^D+0C%C#C% D+&0D DD +D+D+#C%%DD+D D((D+c# UR(a1URR5IShvN SUlSUlggN7f)z?Disconnect from the server. Note: this method is a coroutine. NF)rrr)r#s rr)AsyncSimpleClient.disconnects: >>++((* * *DK"DN  *s/AAAc# U$7fr'r#s r __aenter__AsyncSimpleClient.__aenter__s  sc@# UR5IShvN gN7fr')r))rexc_typeexc_valexc_tbs r __aexit__AsyncSimpleClient.__aexit__soos )rr r rrrrrr')N<)__name__ __module__ __qualname____firstlineno____doc__rr;rr$propertyrBrFrJrOrTr)rZr`__static_attributes__rYrrrrssL*,$4 #;#$?'BLL>>8B(:# rr)rsocketiorsocketio.exceptionsrrrrrYrrrls NNP P r