Nj\%SrSSKJr SSKrSSKrSSKrSSKrSSKJr SSK J r J r J r SSK Jr SSKJrJr SSKJr SS KJr SS KJr SS KJr SS KJr SS KJr SSKJrJ r J!r!J"r"J#r#J$r$ SSK%J&r&J'r' SSK(J)r)J*r*J+r+J,r,J-r- SSK.J/r/J0r0 SSK1J2r2 SSK3J4r4J5r5 SSK6J7r7 SSK1J8r8J9r9J:r: \(awSSK;Jr> SSK?J@r@ SSKAJBrB SSKCJDrDJErEJFrF SSKGJHrHJIrI \""S5rJ\ S \K\>/S4rL\ S \K\M-/S4rN\ S \0/S4rO\ S /S4rP\ S \Q\M/S4rR\S\K\Q4rT\S\K\-4rU\"\S!S"9rVS#\WS$'\"S%S&55rX"S'S(\5rY"S)S*\05rZ"S+S,\Z\45r["S-S.\Z\55r\S8S/jr]"S0S15r^\!S2r_"S3S \^5r`\$"S4S5\^55ra\$"S6S755rbg)9z0 The Curl CFFI WebSocket client implementation. ) annotationsN)InvalidStateError) AwaitableCallable Generator)suppress) dataclassfield)IntEnum)partialdumpsloads)uniform)select) TYPE_CHECKINGClassVarLiteralTypeVarcastfinal)CURL_SOCKET_BAD get_selector) CurlECode CurlFollowCurlInfoCurlOpt CurlWsFlag)Curl CurlError)CurlCffiWarning) SessionClosedTimeout)Response)NOT_SET NotSetTypeset_curl_options)Self)CurlHttpVersion) CurlWsFrame) CookieTypes) HeaderTypes)BrowserTypeLiteralExtraFingerprints ExtraFpDict) AsyncSession ProxySpecT WebSocket),:) separatorsz partial[str] dumps_partialc\\rSrSr%SrSrS\S'SrS\S'S rS \S '\ "S S 9r S\S'Sr g)WebSocketRetryStrategy8u)Configurable WebSocket policy for retrying failed message receives. When enabled, each failed receive attempt will use exponential backoff with jitter. Calculation: ``delay * 2^(count - 1) ± 10%`` Args: retry: Enable or disable WebSocket message receive retry policy. delay: The base value (seconds) to compute the retry delay from. count: How many times to retry a receive operation before giving up. codes: Set of ``CurlECode`` values for which the receive operation should be retried. Default is ``CurlECode.RECV_ERROR``. Fboolretryg333333?floatdelayintcountc$[R1$N)r RECV_ERRORn/root/GenerationalWealth/GenerationalWealth/venv/lib/python3.13/site-packages/curl_cffi/requests/websockets.pyWebSocketRetryStrategy.Ls 9;O;O:PrI)default_factoryzset[CurlECode]codesrHN) __name__ __module__ __qualname____firstlineno____doc__r?__annotations__rArDr rN__static_attributes__rHrIrJr<r<8s6 E4E5E3N!2PQE>QrIr<c`\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrSrSrSrg) WsCloseCodeOz?See: https://www.iana.org/assignments/websocket/websocket.xhtmliiiiiiiiiiiiiii i i rHN)rOrPrQrRrSOK GOING_AWAYPROTOCOL_ERRORUNSUPPORTED_DATAUNKNOWNABNORMAL_CLOSURE INVALID_DATAPOLICY_VIOLATIONMESSAGE_TOO_BIGMANDATORY_EXTENSIONINTERNAL_ERRORSERVICE_RESTARTTRY_AGAIN_LATER BAD_GATEWAY TLS_HANDSHAKE UNAUTHORIZED FORBIDDENTIMEOUTrUrHrIrJrWrWOscI BJNGLONOOKMLIGrIrWc@^\rSrSrSrSSU4SjjjrSrU=r$)WebSocketErrorfzWebSocket-specific error.c$>[TU]X5 grF)super__init__)selfmessagecode __class__s rJrqWebSocketError.__init__is 'rIrH)r)rsstrrtz$WsCloseCode | CurlECode | Literal[0]returnNone)rOrPrQrRrSrqrU __classcell__rus@rJrmrmfs/#JK(("F( ((rIrmc\rSrSrSrSrg)WebSocketClosedozWebSocket is already closed.rHNrOrPrQrRrSrUrHrIrJr}r}os'rIr}c\rSrSrSrSrg)WebSocketTimeoutuzWebSocket operation timed out.rHNrrHrIrJrrus)rIrcHURS5 g![a gf=f)aN Called by the event loop when fd becomes readable/writable. We try to set_result() and silently ignore InvalidStateError which is raised if the future was already finished/cancelled concurrently. This avoids spurious 'Exception in callback' traces in uvloop/asyncio. Intentionally using try/except since this is frequently called. N) set_result_InvalidStateError)futs rJ_safe_set_resultr{s%  t    s  !!c\rSrSr%SrS\S'SSS.SSjjr\SS j5r\SS j5r \SS j5r \ SS j5r \ SS j5r SSjrSrg) BaseWebSocket_curl autoclose _close_code _close_reasondebugclosedztuple[str, ...] __slots__TF)rrcRXlX lSUlSUlX0lSUlg)NFr)rrcurlrrs rJrqBaseWebSocket.__init__s*)- ('+)- ! rIc[UR[5(a[URS9UlUR$)z;Return reference to Curl associated with current WebSocket.)r) isinstancerr)r!rrrs rJrBaseWebSocket.curls/ djj* - -DJJ/DJzzrIcUR$)zThe WebSocket close reason, if the connection has been closed.)rrs rJ close_reasonBaseWebSocket.close_reasons!!!rIc6[R"SU5U-$)N!H)structpack)rtreasons rJ_pack_close_frameBaseWebSocket._pack_close_frames{{4&//rIc[U5S:a[RnSnX4$[R"SU5SnUSSR 5nU[R:Xd US:dUS:a[S U3[R5eX4$![ a n[S[R5UeSnAf[a n[S[R5UeSnAff=f) NrrrzInvalid close messagezInvalid close framerYizInvalid close code: ) lenrWr^r unpack_fromdecodeUnicodeDecodeErrorrmr` Exceptionr\)framertres rJ_unpack_close_frame!BaseWebSocket._unpack_close_frames u:>#++DF&|# ))$6q9qr))+{***dTkTT\$*4&1;3M3M|& $+[-E-E $);+E+E s#-B C%B88 C%C  C%cFSUlURR5 g)z$Terminate the underlying connection.TN)rrclosers rJ terminateBaseWebSocket.terminates  rI)rrrrrrN)rCurl | NotSetTyperr>rr>rxry)rxr!)rxz int | None)rx str | None)rtrCrbytesrxr)rrrxztuple[int, str]rxry)rOrPrQrRrrTrqpropertyrrr staticmethodrrrrUrHrIrJrrs"I=APU"%"59"IM" "   ""000rIr)openrdatarserrorc ^\rSrSrSrSr\4SSSSSSSSS.S!U4SjjjjrS"S jrS#S jr S$S jr SSSS\SS SSSSSS SSSSSSSSSSSS4S%Sjjr S&Sjr S'Sjr S(Sjr\S.S)Sjjr\R$4S*SjjrS+SjrS,SjrS-Sjr\S.S.SjjrS/SjrS0S1Sjjr\R8S4S2SjjrS rU=r$)3r6z)A WebSocket implementation using libcurl.)skip_utf8_validation _emitters keep_runningTFN)rrron_openon_closeon_data on_messageon_errorc>[T U]XUS9 X0lSUl0UlU(aXPRS'U(aX`RS'U(aXpRS'U(aXRS'U (aXRS'gg) a$ Args: autoclose: whether to close the WebSocket after receiving a close frame. skip_utf8_validation: whether to skip UTF-8 validation for text frames in run_forever(). debug: print extra curl debug info. on_open: open callback, ``def on_open(ws)`` on_close: close callback, ``def on_close(ws, code, reason)`` on_data: raw data receive callback, ``def on_data(ws, data, frame)`` on_message: message receive callback, ``def on_message(ws, message)`` on_error: error callback, ``def on_error(ws, exception)`` rrrFrrrrsrN)rprqrrr) rrrrrrrrrrrrus rJrqWebSocket.__init__s|4 duE*>!"'HJ %,NN6 " &.NN7 # %,NN6 " (2NN9 % &.NN7 # rIc>UR(a [S5eU$)NWebSocket is closedrr}rs rJ__iter__WebSocket.__iter__ s ;;!"78 8 rIcfUR5upU[R-(a[eU$rF)recvr CLOSE StopIterationrrmsgflagss rJ__next__WebSocket.__next__s(YY[  :## #  rIc&URRU5nU(a U"U/UQ76ngg![aWnURRS5nU(a U"X5nSnAg[R"SUS3[ SS9 SnAgSnAff=f)NrzWebSocket callback 'z' failedr) stacklevel)rgetrwarningswarnr#)rr event_typeargscallback_rerror_callbacks rJ_emitWebSocket._emits 261C1CJ1O  T)D)   ?C~~?Q?Q@"&t/AMM.zl(C'#$ s / B*B (B  Bzgzip, deflate, brrrcLURn[S 0SU_SS_SU_SSU/_SSU/_SSU/_S U_S U_S U_S U_S SU /_SU _SU _SSU /_SU _SU_SU_SU_SU_SU_SU_SU_SU_SU_SU_SU_SU_SU_6nUR[RS5nUR 5 U$)!aConnect to the WebSocket. libcurl automatically handles pings and pongs. ref: https://curl.se/libcurl/c/libcurl-ws.html Args: url: url for the requests. params: query string for the requests. headers: headers to send. cookies: cookies to use. auth: HTTP basic auth, a tuple of (username, password), only basic auth is supported. timeout: how many seconds to wait before giving up. allow_redirects: whether to allow redirection. Can be a bool, a ``CurlFollow`` value, or the string ``"safe"``. max_redirects: max redirect counts, default 30, use -1 for unlimited. proxies: dict of proxies to use, prefer to use ``proxy`` if they are the same. format: ``{"http": proxy_url, "https": proxy_url}``. proxy: proxy to use, format: "http://user@pass:proxy_url". Can't be used with `proxies` parameter. proxy_auth: HTTP basic auth for proxy, a tuple of (username, password). verify: whether to verify https certs. referer: shortcut for setting referer header. accept_encoding: shortcut for setting accept-encoding header. impersonate: which browser version to impersonate. ja3: ja3 string to impersonate. akamai: akamai string to impersonate. perk: perk string to impersonate. extra_fp: extra fingerprints options, in complement to ja3 and akamai str. default_headers: whether to set default browser headers. default_encoding: Encoding for decoding content if charset is not found. Defaults to "utf-8". quote: Set characters to be quoted (percent-encoded). Default safe string is ``!#$%&'()*+,/:;=?@[]~``. If set to a string, the characters will be removed from the safe string. If set to ``False``, the URL is used as-is (you must encode it yourself). http_version: Limiting http version, defaults to http2. interface: which interface to use. cert: a tuple of (cert, key) filenames for client cert. max_recv_speed: maximum receive speed, bytes per second. curl_options: extra curl options to use. rmethodGETurl params_listN headers_list cookies_listauthtimeoutallow_redirects max_redirects proxies_listproxy proxy_auth verify_listrefereraccept_encoding impersonateja3akamaiperkextra_fpdefault_headersquote http_version interfacemax_recv_speedcert curl_optionsrrH)rr*setoptr CONNECT_ONLYperform)rrrparamsheaderscookiesrrrrproxiesrrverifyrrrrrrrrrrrrrrrrs rJconnectWebSocket.connect,sgZYY     v        , (   " v  ,! "$# $% &' () *+ ,,- ./ 0&1 2 3 4*5 67 8&9 @ KK,,a 0  rIcUR(a [S5eURR5upUR[ R -(a@URU5uUlUl UR(aUR5 X4$![a2nURUlURUR5 eSnAff=f)z2Receive a single curl websocket fragment as bytes.WebSocket is already closedN)rr}rws_recvrr rrrrrmrtrr)rrchunkrrs rJ recv_fragmentWebSocket.recv_fragments ;;!"?@ @yy((*  ;;)) ) 7;7O7OPU7V4 $"4~~ |" $%66  166"  sB C(-CCc/nSnURR[R5nU[:Xa[ S[ R5eUR5upEURnURU5 URS:XaU[R-S:XaOMZSR%U5U4$![a<nUR[ R :Xa[#U///S5u nSnANUeSnAff=f)zs Receive a frame as bytes. libcurl splits frames into fragments, so we have to collect all the chunks for a frame. rInvalid active socket?NrI)rgetinfor ACTIVESOCKETrrmrNO_CONNECTION_AVAILABLErrappend bytesleftr CONTr"rtAGAINrjoin)rrchunksrsock_fdrrrrs rJrWebSocket.recvs !))##H$9$9: o % ')J)J  #113   e$??a'EJOO,Cq,H xx&& 66Y__,%gYBiik  ' !79Q9QR R{{7##rIrc2UR5nU"U5$)zMReceive a JSON frame. Args: loads: JSON decoder, default is json.loads. )r%)rrrrs rJ recv_jsonWebSocket.recv_jsons }}T{rIcU[R-(aSUlUR(a [ S5e[ U[ 5(aUR5nURR[R5nU[:Xa[S[R5eSnU[!U5:a5XSnURR#XR5nXF- nU[!U5:aM5U$![$aOnUR&[R(:Xa+[+/U//S5upnU (d [S5UeSnAMeSnAff=f)zUSend a data frame. Args: payload: data to send. flags: flags for the frame. FrrrNrzSocket write timeout)r rrrr}rrwencoderrrrrrmrrrws_sendr"rtrr) rrpayloadrr offsetcurrent_buffern_sentrr writeables rJsendWebSocket.sends& :## # %D  ;;!"?@ @ gs # #nn&G))##H$9$9: o % ')J)J  s7|#$W-N **>A  Fs7|#  66Y__,&,R'B&DOA!$,-CD!K  sC66 EAE  E  EcBURU[R5$)z>Send a binary frame. Args: payload: binary data to send. r2r BINARYrrr-s rJ send_binaryWebSocket.send_binary yy*"3"344rIcBURU[R5$)z\Send a binary frame, alias of :meth:`send_binary`. Args: payload: binary data to send. r5r7s rJ send_bytesWebSocket.send_bytesr:rIcBURU[R5$)z:Send a text frame. Args: payload: text data to send. r2r r$r7s rJsend_strWebSocket.send_str# yy*//22rIr c0URU"U55$)zeSend a JSON frame. Args: payload: data to send. dumps: JSON encoder, default is json.dumps. r@rrr-rs rJ send_jsonWebSocket.send_json+s}}U7^,,rIcBURU[R5$)z5Send a ping frame. Args: payload: data to send. )r2r PINGr7s rJpingWebSocket.ping6rBrIc <U(aUR"U40UD6nURR[R5nU[ :Xa[ S[R5eURS5 /nSUl UR(GazUR5upgURnURSXg5 URU5 URS:XaU[R -S:XdM}SUR";aSR%U5n U[R&-(a#UR((dU R+5n OU n U[R6-(dU[R&-(aURSU 5 /nU[R8-(a@S Ul URS UR2=(d SUR:=(d S 5 UR(aGMyg g ![,aTn [.R0UlUR5[.R05 [ S[.R05U eS n A ff=f![<an U R>[R@:Xa[CU///S 5u nS n A NURSU 5 URD(dB[.RFn [IU [ 5(a U R>n UR5U 5 eS n A ff=f)zRun the WebSocket forever. See :meth:`connect` for details on parameters. libcurl automatically handles pings and pongs. ref: https://curl.se/libcurl/c/libcurl-ws.html rrTrrrsrIz Invalid UTF-8NFrrrr)%r rrrrrrmrrrrrrrrr rrrr$rrrrWr`rrr6rrr"rtrrrr^r) rrrkwargsrr rrrrremit_msgrrts rJ run_foreverWebSocket.run_forever>s^  S+F+A))##H$9$9: o % ')J)J  6! . #113   650 e$1,1HA1M.((6*C /9R9R%47JJLH$' 1 11uz7N 9h7:+++(-D%JJw(8(8(=At?Q?Q?WUWXG$ 2%/:/G/GD, JJ{'?'?@"0 /1I1I##$%%& 66Y__,$gYBrr>rr>rzON_OPEN_T | NonerzON_CLOSE_T | NonerzON_DATA_T | NonerzON_MESSAGE_T | NonerzON_ERROR_T | Nonerxry)rxr6rxr)rEventTypeLiteralrz+str | bytes | int | CurlWsFrame | CurlErrorrxry)6rrwrz\dict[str, object] | list[object] | tuple[str, int | list[str] | dict[str, str | int]] | NonerzHeaderTypes | Noner zCookieTypes | Nonertuple[str, str] | Nonerz+float | tuple[float, float] | object | Nonerzbool | CurlFollow | strrrCr zProxySpec | NonerrrrUr z bool | NonerrrrrzBrowserTypeLiteral | Nonerrrrrrrz&ExtraFingerprints | ExtraFpDict | Nonerr>rzstr | Literal[False]rzCurlHttpVersion | Nonerrrzstr | tuple[str, str] | NonerrCrzdict[CurlOpt, str] | Nonerxr+)rxztuple[bytes, CurlWsFrame])rxtuple[bytes, int])rxrw)rzCallable[[str], T]rxr5)r- str | bytesrr rxrC)r-rrxrC)r-r)r-rwrxrC)r-objectrCallable[..., str]rxrC)r-rWrxrC)r)rrwrxry)rtrCrsr) rOrPrQrRrSrr(rqrrrr rrr% json_loadsr(r r6r2r8r<r@r:rFrJrOrWrZrrUrzr{s@rJr6r6s3I#*(/%*$(&*$(*.&*(/(/ (/ # (/  (/"(/$(/"(/((/$(/ (/(/T  $;  @ &*&*'+?F37$( -1""&915!;? $&(/3 $-126Ap p  p$p$p%p=p1pp"p !p"+#p$%p&'p($)p*/+p,-p./p01p293p45p6$7p8-9p:;p<+=p>?p@0ApB Cpd,'@$8B'----- -^553?L - -); -  -3EN!,  rIc `^\rSrSr%SrSrSrS\S'SSS S S SS S S SSSS. S1U4Sjjjr\ S2Sj5r \ S3Sj5r S4Sjr S5Sjr S6SjrS5SjrS7SjrS8SjrS9SjrS S.S:SjjrS S.S;Sjjr\S S.SS jrS>S!jrS?S"jr\S#.S@S$jjrSAS%jr\ RBS&S'4SBS(jjr"S9U4S)jjr#S9S*jr$S9S+jr%SCS,jr&SDSES-jjr'S9U4S.jjr(SFS/jr)S0r*U=r+$)GAsyncWebSocketiz4 An asyncio WebSocket implementation using libcurl. )session_loop_sock_fd _close_lock_terminate_lock _read_task _write_task_receive_queue _send_queue_max_send_batch_size_coalesce_frames_recv_time_slice_send_time_slice _terminated_terminated_eventws_retry_transport_exception_max_message_sizedrain_on_error_block_on_recv_queue_fulliz ClassVar[int]_MAX_CURL_FRAME_SIZETF Ng{Gzt?gMbP?i@) rrrecv_queue_sizesend_queue_sizemax_send_batch_sizecoalesce_framesrlrecv_time_slicesend_time_slicemax_message_sizeroblock_on_recv_queue_fullc >[TU]X#US9 XlSUlSUlSUl[ R"5Ul[R"5Ul [ R"5Ul SUl SUl[ R"US9Ul[ R"US9UlXplXlU =(d [)5UlXlXlSUlXlXlXlg)aInitializes an Async WebSocket session. Do not instantiate this class directly. Use ``AsyncSession.ws_connect``. This class implements an async context manager, closing the connection automatically on exit: :: async with AsyncSession() as session: async with session.ws_connect("wss://api.example.com") as ws: await ws.send("Hello") msg = await ws.recv() Note: Architecture: This uses a decoupled I/O model. Network operations run in background tasks. Errors are raised in subsequent calls to send() or recv(). Performance: The time_slice defaults (5ms read / 1ms write) favor reading to compensate for libcurl's overhead. Increase these values to allocate more CPU time to I/O operations at the cost of event loop latency. Args: session (AsyncSession): The parent session object. curl (Curl): The underlying Curl handle. autoclose (bool): Automatically close on receiving a close frame. debug (bool): Enable verbose debug logging. recv_queue_size (int): Max number of incoming messages to buffer. send_queue_size (int): Max number of outgoing messages to buffer. max_send_batch_size (int): Max frames to coalesce per transmission. coalesce_frames (bool): Combine small frame payloads to improve throughput. ws_retry (WebSocketRetryStrategy): Retry configuration for failed receives. recv_time_slice (float): Max seconds to read messages before yielding. send_time_slice (float): Max seconds to write messages before yielding. max_message_size (int): Max size (bytes) of a single received message. drain_on_error (bool): Yield buffered messages before raising errors. block_on_recv_queue_full (bool): Behavior when the receive queue is full. If True (default), the reader blocks (may cause timeouts). If False, the connection fails immediately to prevent data loss. See also: - https://curl.se/libcurl/c/curl_ws_recv.html - https://curl.se/libcurl/c/curl_ws_send.html rNF)maxsize)rprqr]r^r_rjasyncioLockr` threadingraEventrkrbrcQueuerdrerfrgr<rlrhrirmrnrorp)rrr]rrrrtrurvrwrlrxryrzror{rus rJrqAsyncWebSocket.__init__s| duE/6 7;  !&)0/8~~/?07 596:>Emm#? &>&@ADJzzrIc6URR5$)z6Returns the current number of items in the send queue.)reqsizers rJruAsyncWebSocket.send_queue_sizes%%''rIcUR(dUR(agUR(a URR5(agUR=(a URR5(+$)ab Checks if the background I/O tasks are still running. Returns ``False`` if either the read or write task has terminated due to an error or a clean shutdown. Note: This is a snapshot in time. A return value of ``True`` does not guarantee the next network operation will succeed, but ``False`` definitively indicates the connection is no longer active. F)rrjrbdonercrs rJis_aliveAsyncWebSocket.is_alivesU ;;$** ??t3355$$@)9)9)>)>)@AArIc# U$7f)aEnable context manager usage for automatic session management and closure. This cannot be used to initiate a WebSocket connection, that must be done beforehand using the :meth:`AsyncSession.ws_connect()` factory method. Returns: Self: The instantiated AsyncWebSocket object. rHrs rJ __aenter__AsyncWebSocket.__aenter__+s  sc@# UR5IShvN gN7f)zA On exiting the context manager, close the WebSocket connection. N)r)rrexc_typeexc_valexc_tbs rJ __aexit__AsyncWebSocket.__aexit__5sjjls c>UR(a [S5eU$)NzWebSocket has been closedrrs rJ __aiter__AsyncWebSocket.__aiter__@s ;;!"=> > rIc# UR5IShvN upU[R-(a[eU$N&![a [Sef=f7frF)rr}StopAsyncIterationr rrs rJ __anext__AsyncWebSocket.__anext__EsP /#yy{*JC :## #$ $ + /$$ . /s)AA>A AAAAcnUR(d URbgXlUR5 g)aFinalize the connection into a terminal state. This method is called for all terminal conditions, including: - normal WebSocket closure - protocol errors - transport errors After this method is called, no further messages will be delivered and all ``recv()`` calls will fail. ``_finalize_connection()`` is intended for event-loop context, but ``terminate()`` is thread-safe. Args: exc (Exception): The exception object that gets raised. This does not have to be an error, enqueuing ``WebSocketClosed`` indicates closure. N)rrmr)rrexcs rJ_finalize_connection#AsyncWebSocket._finalize_connectionOs)" ;;$33? $'! rIcURbgUR(a [S5e[[UR R [R55Ul UR[:Xa[S[RS9eS[U5S3nURR!UR#5US3S9UlURR!UR%5US 3S9Ulg) zStart the read/write I/O loop tasks. NOTE: This should be called only once after object creation by the factory. Once started, the tasks cannot be restarted again, this is a one-shot. Raises: WebSocketError: The WebSocket FD was invalid. NzWebSocket already terminatedzInvalid active socket.)rtz WebSocket-z#xz-read)namez-write)rbrjr}rrCrrrrr_rrmrridr create_task _read_loop _write_looprc)rrws_ids rJ_start_io_tasksAsyncWebSocket._start_io_tasksfs ?? &    !"@A AS$))"3"3H4I4I"JK ==O + (y/P/P  ""T(2/))//0A5'QV/X9900    wf%51 rIrc # URbUR(d UReURR5$![R a Of=fURb UReUR bUR R5(a [S5e[R"URR55n[R"X R 4[RUS9IShvN up4O}![Raf UR5(dOUR5n[[R5 UIShvN SSS5 e!,(df  e=fef=fU(dUR5n[[R5 UIShvN SSS5 O!,(df  O=fURb URe[!S["R$5eX#;a UIShvN $UR5n[[R5 UIShvN SSS5 O!,(df  O=fUR(aN[[R 5 URR5sSSS5 $!,(df  O=fURb URe[S5e7f)aReceive a WebSocket message. This method waits for and returns the next complete WebSocket message. Args: timeout: How many seconds to wait for a message before raising a timeout error. Returns: tuple[bytes, int]: A tuple with the received payload and flags. Raises: WebSocketTimeout: If the timeout expires. WebSocketClosed: If the connection is closed. WebSocketError: If a network-level transport error occurs. Notes: ``WebSocketError`` exceptions may have originated from a prior ``send()`` or ``recv()`` operation, since all operations share the same transport state once a failure occurs. This method does not wait for additional messages after a transport error is detected. If ``drain_on_error=True``, subsequent calls to ``recv()`` will return any messages that were buffered in the receive queue at the time the reader failed, before the connection error is raised. Concurrent calls to ``recv()`` are supported and safe; each caller awaits the next available message and will receive distinct messages in FIFO order. If this coroutine is cancelled while a message is being received, that message may be dropped. Cancellation is treated as abandoning the receive operation. Nr return_whenrzWebSocket recv() timed outzConnection closed)rmrord get_nowaitr QueueEmptyrbrr}rrwaitFIRST_COMPLETEDCancelledErrorcancelrrrOPERATION_TIMEDOUT)rrr queue_waiterrrs rJrAsyncWebSocket.recvsdH  $ $ 09L9L++ + &&113 3!!     $ $ 0++ + ?? "doo&:&:&<&<!"78 87>6I6I    # # %7  #LL/#33GD!%% $$&& '')g445&&&6 65 E  ##%A'001"""211((4///",i.J.J   %%% %    ! g,, -  . - -   ',,-**557.--  $ $ 0++ +122s+LALALABL!2DDDLAF.F4E75F: F F F3L GGG L G,(AL,H/-.LI0!I$"I0' L0 I>:1L+K L K+Lc"# URUS9IShvN up#U[R-(d[S[R 5eUR S5$NJ![a n[S[R 5UeSnAff=f7f)zUReceive a text frame. Args: timeout: how many seconds to wait before giving up. rNzNot a valid text framer#zInvalid UTF-8 in text frame)rr r$rmrWr`rr)rrrrrrs rJr%AsyncWebSocket.recv_strs !IIgI66  ' !9;;S;ST T ;;w' ' 7 "  -{/G/G  s3BA 8BA"B" B ,BB  B)rrcD# URUS9IShvN up4U(d[S[R5eU"U5$N0![a n[S[R5UeSnAf[ a#n[SU3[R5UeSnAff=f7f)zReceive a JSON frame. Args: loads: JSON decoder, default is :meth:`json.loads`. timeout: how many seconds to wait before giving up. Raises: WebSocketError: Received frame is invalid or failed to decode JSON. rNz(Received empty frame, cannot decode JSONz Invalid UTF-8 in JSON text framezInvalid JSON payload: )rrmrWr`rr)rrrrrrrs rJr(AsyncWebSocket.recv_jsons ' 22 :KB A'B AB  BA-- B:BBB c# URb UReUR(a [S5eURb*URR 5(a [S5e[ U[ 5(aURS5nO'[ U[[-5(a [U5nURRX45 g![RanUR(a [S5UeURb URUeUbd[R "URR#X45U5IShvN OM![R$an['S5UeSnAff=fURR#X45IShvN URb URUeSnAgSnAff=f7f)aSend a data frame. Large payloads are automatically split into fragments but arrive as a single logical message. Args: payload: Data to send (``str``/``bytes``/``bytearray``/``memoryview``). flags: Frame type flags (e.g., ``CurlWsFlag.TEXT``). timeout: Max seconds to wait if the send queue is full. Warning: This method is non-blocking. It queues the message for background transmission. Use ``await ws.flush()`` to ensure data is sent to the socket. Nrz(WebSocket writer terminated; cannot sendr#z"WebSocket connection is terminatedz>Send queue full (network slow) - hit timeout enqueuing message)rmrr}rcrrrwr+ bytearray memoryviewrre put_nowaitr QueueFullrjwait_forput TimeoutErrorr)rrr-rrrrs rJr2AsyncWebSocket.send#s*  $ $ 0++ + ;;!"78 8    'D,<,<,A,A,C,C!"LM M gs # #nnW-G Z!7 8 8GnG 9    ' '(8 9   9%&JKQTT((4//S8"!**((,,g-=>++*X &&**G+;<<<((4//S85+ 9slB;G>CGG/:G*4E%E!E%$G%F 9 FF  "G,F/-G GGGc^# URU[R5IShvN $N7f)zsSend a binary frame. Args: payload: binary data to send. For more info, see the docstring for :meth:`send()` Nr5r7s rJr8AsyncWebSocket.send_binaryb$YYw (9(9:::: $-+-c^# URU[R5IShvN $N7f)zSend a binary frame, alias of :meth:`send_binary`. Args: payload: binary data to send. For more info, see the docstring for :meth:`send()` Nr5r7s rJr<AsyncWebSocket.send_byteslrrc^# URU[R5IShvN $N7f)zoSend a text frame. Args: payload: text data to send. For more info, see the docstring for :meth:`send()` Nr?r7s rJr@AsyncWebSocket.send_strvs"YYw 8888rr cL# URU"U55IShvN $N7f)zSend a JSON frame. Args: payload: data to send. dumps: JSON encoder, default is :meth:`json.dumps()`. For more info, see the docstring for :meth:`send()` NrDrEs rJrFAsyncWebSocket.send_jsons ]]5>2222s $"$c@# [U[5(aURS5nO [U5n[ U5[ SS5;a&[ S[ U53[R5eURU[R5IShvN $N7f)zSend a ping frame. Args: payload: data to send. Raises: WebSocketError: The payload length is outside specification. For more info, see the docstring for :meth:`send()` r#r~zPing frame has invalid length: N) rrwr+rrrangermr TOO_LARGEr2r rI)rrr- payload_bytess rJrJAsyncWebSocket.pings gs # ##NN73M!'NM } U1c] 2 1#m2D1EF##  YY}joo>>>>sBBBBrIg@c # URIShvN UR(aSSS5IShvN gSUlUR(aURR5(d}URcpUR X5n[ R"URRU[R45US9IShvN URU5IShvN UR5 [![ R5 [ R"UR"R%5U5IShvN nSSS5 SSS5IShvN gGNWGN8NN![ R[4a Nf=fNG!,(df  NK=f!UR5 [![ R5 [ R"UR"R%5U5IShvN nSSS5 f!,(df  f=f=fN!,IShvN (df  g=f7f)a Performs a graceful WebSocket closing handshake and terminates the connection. This method sends a WebSocket close frame to the peer, waits for queued outgoing messages to be sent, and then shuts down the connection. Args: code (int): Close code. Defaults to ``WsCloseCode.OK``. message (bytes): Close reason. Defaults to ``b""``. timeout (float): How long (in seconds) to wait for the connection to close gracefully before force-terminating. NTr)r`rrcrrmrrrrerr rflushrrmrrrkr)rrrtrsr close_framers rJrAsyncWebSocket.closes###{{$##DK W$$ ,,1133119*.)?)?)NK!**((,,k:;K;K-LM '**W--- g223%..t/E/E/J/J/LgVVA45$##.((.9  W43 g223%..t/E/E/J/J/LgVVVA4335$###sIE*IH) IE-IH)BE4E0E4+E2,E40)H)3F F FH) I$H'%I-I0E42E44FF'FF'F F$ H)'*H$3H H H H$ H! H$$H)'I)I/H2 0 I<Ic>UR UR(a SSS5 gSUlURn[R"5nUc [ S5eUb$X!La UR UR55nO&[R"UR5U5nSSS5 g![ a SnNsf=f![a [TU]-5 UR(a6URR(dURRS5 URR!5 N!URR!5 f=ff=f!,(df  g=f)a Immediately terminates the connection without a graceful handshake. This method is a forceful shutdown that cancels all background I/O tasks and cleans up resources. It should be used for final cleanup or after an unrecoverable error. Unlike ``close()``, it does not attempt to send a close frame or wait for pending messages. It schedules the cleanup to run on the event loop and returns immediately. It does not wait for cleanup completion. This method is thread-safe, task-safe, and idempotent. NTzEvent loop not available)rarjr^rr RuntimeErrorr_terminate_helperrun_coroutine_threadsaferrprr]_closed push_curlrkset)rrr current_looprrus rJrAsyncWebSocket.terminates4 ! !" ! $D 59ZZD $,,.  1<&'ABB + 0D(()?)?)ABA889O9O9QSWXA/" !  $#  $ 11G%'||DLL,@,@ ..t4**..0D**..0 15" !spE)E)B84C E) %C .E)8 CE)CE) E&AE*E&E)E""E&&E)) E7c  ^-# URRnURRnURRnUR nUR nURnURnURnURn U"5U -n URRn URRn URRn [URR 5n["R$n["R&n["R(n[*R,n[*R.n[*R0nUU-nUR2nUR4nSnSn[6nSn/nSnUR8nUR:nUR<(GddU"5un n!U!Rdn*US:aSnU*U-(dU[gU 5- nUU:a8U"5 URS[YSUSUS3["Rh55 gU"U 5 U*U-(dJU!Rj(d9[gU5S :XaUSOSRmU5n+U"5 SnU"U+U*45 U"5=n,U :a#[^R`"S5IShvN U,U -n GMU*U-(a,U"5 U"U U*45 URsU 5IShvN gU*U-(a U"U U*45 UR<(dGMcgg![>Ga_n"Sn#U"R@U:XaSn#OU"R@U:Xa6[CU"5RE5m-[GU-4SjU55(aSn#ONU"R@U:Xa>[IS[JRL5n$U"U$l'SU$l(URSU$5 Sn"A"gU#(Ga!U"5n%U"URTUU%5 U%IShvN O![Vavn&URS[YS U&3["RZ55 Sn&A&URTS :wa,U"URT5n'Sn"A"g![Va Sn"A"gf=fSn"A"gSn&A&ff=fURTS :wa$U"URT5n'OJ![Va O>f=fO9!URTS :wa$U"URT5n'f![Va ff=ff=fSn"A"GMTU (akU"R@U ;a[UU :aUUS - nUS US - --n(U(S -n)U([]U)*U)5- n([^R`"[cSU(55IShvN Sn"A"GMURSU"5 Sn"A"gSn"A"ff=f![^RnaI U(d+URS[YU["Rp55 gU"U+U*45IShvN GN]f=fGN;![^RnaI U(d+URS[YU["Rp55 gU"U U*45IShvN GNqf=fGNa![^RnaI U(d+URS[YU["Rp55 gU"U U*45IShvN GNf=f![^Rta g[Van"URSU"5 Sn"A"gSn"A"ff=f7f)a) The main asynchronous task for reading incoming WebSocket frames. Attempts to read immediately and only registers an event loop reader if the socket returns EAGAIN (empty). It waits for the underlying socket to become readable, and upon being woken by the event loop, it drains all buffered data from libcurl until it receives an EAGAIN error. This error signals that the buffer is empty, and the loop returns to an idle state, waiting for the next readability event. This is "optimistic reading". To ensure cooperative multitasking during high-volume message streams, the loop yields control to the asyncio event loop periodically which is tracked using an operation counter. If the receive queue becomes full, ``await self._receive_queue.put()`` will block the reader loop and stall the socket read task. Thus, appropriate queue sizes should be set by the user, to match the speed at which they are expected to be consumed. If latency is a factor, a smaller queue size should be used. Conversely, a larger queue size provides burst message handling capacity. )zerrno 11z resource temporarily unavailablezDReceive queue full; failing connection to preserve message integrityrFTc3,># UH oT;v M g7frFrH).0rerr_msgs rJ ,AsyncWebSocket._read_loop..SsG#g~sz.Connection closed unexpectedly by server (EOF)NzSocket closed unexpectedly: r}r$rg?gzMessage too large: z bytes (limit zF bytes). Consider increasing max_message_size or chunking the message.rI);rrrdrrrtime create_future add_reader remove_readerrhrlr?rNrDr@rArrrG GOT_NOTHINGr rrrIrnrprrclearrr"rtrwloweranyr}rWr_ __cause____suppress_context__rr_rrmrrrsleepmaxrrrrrr OUT_OF_MEMORY_handle_close_framer).rr curl_ws_recvqueue_put_nowait queue_putr loop_timerrr time_slice next_yieldretry_on_error retry_codes max_retries retry_basee_again e_recv_err e_nothing close_flag cont_flag ping_flag control_mask max_msg_size block_on_recv errno_11_msgsqueue_full_errset_fut_resultrecv_error_retriesrmsg_size chunks_append chunks_clearrrr should_retry final_exc read_futurerr retry_delayjitterrrsnowrs. @rJrAsyncWebSocket._read_loopsp.AE @Q@Q    * *     # # +/)))- <@LE5T#[[%))*& ,E *H,.$11*&9(D..:^<<%< !* 3 3 "%("I-),V)9F1Isxx?O %#$ >,gu-=> ){*z9%mmA...%(:%5  :% N 8(%82259999$ 8(%8mkkk!F).Lvv('+ :-'*1v||~GGGG+/L9,5DL'886 /0 +9= 611)<##0 $ 9 9$2(6 8O8O%&!" !'"+We,<"===>/#,,8, 55 .~y?V?V W#'7778:#,,8, 55 .~y?V?V W#'7778%%   )  % %a ( ( )swF[&Z)2 LU;R"!U;" R/,U;.R//U;3S)SS) S% "S)$S% %S))U;,Z)3A%U;UU;Z)%U;6Z):[&;VZ)AW Z)[& W WW Z)W  Z)&AY*Z)+[&, Y9X<:Y?Z)YZ) AZ& Z)[& Z&ZZ&"Z)%Z&&Z))[#=[&? [#[[&[##[&c # [R[R-nURnURR nURR nURRnURnURnURnU"5U-n UR(dU"5IShvN upU"X5IShvN (d+U"5 UR(dUR5 ggU [R-(a U"5 GO(U"5=o:a"[R"S5IShvN X-n U"5 MU"5IShvN upX4/n U [R-(dj[!U 5UR":aQU"5upU R%X45 U[R-(aO[!U 5UR":aMQ0nU GHupX-(GaUUR)5HunnU"SR+U5U5IShvN (dG [-[!U 55H nU"5 M UR(dUR5 ggU"5=o:dM[R"S5IShvN X-n M UR/5 U"X5IShvN (dF [-[!U 55H nU"5 M UR(dUR5 ggU"5=o:a%[R"S5IShvN X-n GMbGMeUR1U/5R%U 5 GM UR)5HqunnU"SR+U5U5IShvN (aM- [-[!U 55H nU"5 M UR(dUR5 gg [-[!U 55H nU"5 M U SS[R-(aOGMUR(dUR5 ggGNGNGN,!U"5 f=fGN![R&a GMf=fGNjGNGNGN^N![-[!U 55H nU"5 M f=f![R2a N[4anUR7U5 SnANSnAff=f!UR(dUR5 ff=f7f)a The background task responsible for consuming the send queue and transmitting frames. To maximize performance, this loop hoists the configuration check and enters one of two distinct processing strategies: 1. Standard Mode (No Coalescing): The default, low-latency path. Messages are consumed one-by-one from the queue and transmitted immediately. This guarantees that one ``send()`` call results in exactly one WebSocket message, preserving logical message boundaries. 2. Coalescing Mode: An optimized throughput path for chatty streams. The loop greedily gathers multiple pending messages from the queue (up to ``max_send_batch_size`` and merges their payloads into a single transmission if they share the same flags (e.g., multiple text frames). This reduces system call overhead but does not preserve individual message boundaries. Features: - Cooperative Multitasking: Yields to the event loop periodically to prevent the writer from starving the reader task during high-volume transmission. - Control Frame Priority: PING and CLOSE frames are never coalesced; they trigger an immediate flush of any pending batched data before being sent. - Lifecycle Management: Automatically terminates the connection cleanly upon transmitting a CLOSE frame. NrrIr}r$)r rrI _send_payloadrerr task_donerrrirgrrrrrrfrritemsrrr setdefaultrrr)rrcontrol_frame_flags send_payload queue_getqueue_get_nowait queue_donerrrrr-rrbatchrdata_to_coalesce frame_grouppayloadsrrs rJrAsyncWebSocket._write_loops:$.#3#3joo#E7;7I7I >B>N>N>R>R :>:J:J:U:U)-)9)9)C)C *.)))-  11 %K*4 ] !((+4;%6NG %%1'%AAA"# P;; c!:#3#33!# $-;.C=")--"222),)9J# !(+4;%6NG?F=M#(:+;+;#;$)$< "%j4+D+DD%)JL(.3NG$::=M=S=S=U$9K1=(+(:K2&,&,&)/6"'s5z!2A&L"3 ;; Q09{(:'I.5mmA.>(>(>585E >V!1 6 6 8-9'-I'I'I$*""'s5z!2A&L"3 ;; =,5;$6C#E*1--*:$:$:141AJ$F !1 ; ;E2 F M Mg V3/486F5K5K5M1K)5chhx6H+)V#V#V &"'s5z!2A&L"3 ;; -6N "'s5z!2A&L"3Ry|j&6&66sH;; o&7 B3# &7$+#5#5& %&,&)? (J %;$W "'s5z!2A&L"3%%   )  % %a ( ( ) ;; sBT?!S=Q2>S Q;Q5 Q;S"#T?Q;S%T'%Q; Q8 Q;S)R*;S&3R S7AR4<R&= R4"S*#T? R4R44R)5'R4R, R4'"S #T?,%R4R/A%R47R28R4R4"S&#T? R4 AS T S#T?2S5Q;8Q;; RS R#S"R##S&R4)R4,R4/R42R44$SST/T1 T:T TTT$T<<T?c# URRnURnURnURnUR nUR n[n URn URn U"5U -n URn [Rn[RnSnX/)-n[U5n[!U5nSnSnUU:d US:XaUS:XaUUU[#UU- U 5-n[!U5nUnUU-U:aUU-nU"UU5nUS:XaRUS:XagUS:aEUS- nUU:a.UR%['SUS3[R(55 g[+SU5eU(aSnUU- nU"5=nU :a#[,R."S5IS hvN UU -n UU:aMUS:XaUS:XaMgN ![*GanUR0U:XaU"5nU"XU5 UIS hvN Oo![2abnUR%['S U3[R455 S nAU S :wa"U"U 5nS nAg![2a S nAgf=fS nAgS nAff=fU S :waU"U 5nO6![2a O*f=fO%!U S :waU"U 5nf![2a ff=ff=fS nAGMUR%U5 S nAgS nAff=f7f) z6 Optimized low-level sender with fragmentation logic. rBrTr$zWriter stalled (z attempts).Fz 0 bytes sentNz)Socket closed unexpectedly during write: r})rr,rrr add_writer remove_writerrr_rirqrrr rrrminrrm WRITE_ERRORr"rrrtrr)rrr-r curl_ws_sendrrrr)r*r r rrmax_frame_sizerrmax_zero_writes base_flagsview total_bytesr. write_retriesr chunk_len current_flagsr0rr write_futurerrs rJrAsyncWebSocket._send_payloadrs GKiiFWFW *.)))- <@G!K"AG"G# G,K4 KKG KK(G=6G97G=<J= I),I$3J7K>I K IKKIKK$I))J-K4I=<K= J K J  KJ0JJ0 J, )J0+J, ,J00K3K:K KKKcN# URcg[R"URR 55n[R "X R1[R US9IShvN up4U(d [S5eX#;aTUR5(d=UR5n[[R5 UIShvN SSS5 ggURU;aURR5 URR5(aTUR5(d=UR5n[[R5 UIShvN SSS5 gg[S5eUR5(d=UR5n[[R5 UIShvN SSS5 ggGNoGN!,(df  g=f![an[S5UeSnAff=fN!,(df  g=fNV!,(df  g=f!UR5(dOUR5n[[R5 UIShvN SSS5 f!,(df  f=ff=f7f)aLWaits until all items in the send queue have been processed. This ensures that all messages passed to `send()` have been handed off to the underlying socket for transmission. It does not guarantee that the data has been received by the remote peer. Args: timeout (float | None, optional): The maximum number of seconds to wait for the queue to drain. Raises: WebSocketTimeout: If the send queue is not fully processed within the specified ``timeout`` period. WebSocketError: If the writer task has already terminated while unsent messages remain in the queue. Nrz*Timed out waiting for send queue to flush.z#Writer task crashed while flushing.z0Writer task stopped unexpectedly while flushing.)rcrrrerrrrrrrrresultrrmempty)rrr join_taskrrrs rJrAsyncWebSocket.flushs)"    # )0(;(;D>##$$&g445#OO65$4'Y$$++- ##))++ >>##$$&g445#OO65$ %%WXX(>>##$$&g445#OO65$9>$65!Y()NOUXXY$65#65>>##$$&g445#OO655$s =J%2H<2G!3H<>J%G'G$G' J%$H<5G8H</>J%-H3H4H8 J% H<>J% H+H)H+ J%!H<$G'' G51J%8 H HHH<H H&"J%)H++ H95J%# URUR4Vs1sH!nUcMUR5(aMUiM# nnSnUHnUR5nM U(aG[R "UU[R S9IShvN upVUHnUR5nM URR5(dVURR5nURR5 URR5(dMVURS:waz[[5 UR R#UR5nSSS5 [[5 UR R%UR5nSSS5 SUl [&TU]Q5 UR*(a6UR*R,(dUR*R/S5 UR0R35 gs snfGN![R[4a GM'f=f!,(df  N=f!,(df  N=f!UR0R35 f=f7f)z)Utility method for connection terminationNr)rrr})rbrcrrrr ALL_COMPLETEDrer:rrr ValueErrorr_rrrrr*rprr]rrrkr) rrttasks_to_cancel max_timeoutio_taskrpendingprus rJr AsyncWebSocket._terminate_helpersoot'7'784 8 %&VVX 8 4  ( )*NN$+#*<<#' ' 5 5$  !A A!&&,,..((335A$$..0&&,,..}}"i( // >A)i( // >A)DM G  ||DLL$8$8 &&t,  " " & & (_4  **J7 )(((  " " & & (sJH(H(H(J AI4H->I44H0I4'I4&I,I4&I#)A$I4 J-I40I I4II4 I I4# I1-I44JJcx# URU5uUlUlUR (aLUR (d;URUR=(d [R5IShvN gUR5 g![anURUlSnANSnAff=fN>7f)z>$++**T--?@ @ @ NN  & vvD   & As:B:BAB:9B8:B: B5B0+B:0B55B:)rprr`rrgr^rnrfrbrdrhrerir_rarjrkrmrcrror]rl)r]r3rr!rr>rr>rtrCrurCrvrCrwr>rlzWebSocketRetryStrategy | Nonerxr@ryr@rzrCror>r{r>rxry)rxzasyncio.AbstractEventLoop)rxrC)rxr>)rxr+)rtype[BaseException] | NonerBaseException | Noner object | NonerxryrS)rrrxryr)r float | NonerxrV)rrLrxrw)rzCallable[[str | bytes], T]rrLrxr5)r-z$str | bytes | bytearray | memoryviewrr rrLrxry)r-rrxry)r-rwrxry)r-rXrrYrxry)r-rWrxry)rtrCrsrrr@rxry)r-rrzCurlWsFlag | intrxr>rF)rrLrxry)rsrrxry),rOrPrQrRrSrrqrTrqrrrurrrrrrrrr%rZr(r r6r2r8r<r@r:rFrJrWrZrrrrrrrrrUrzr{s@rJr\r\sI.+0-/!!#% %26!&!& /$)-!VHVHVH  VH  VHVHVH!VHVH0VHVHVHVHVH #'!VH" #VHVHp ((B& , &     .  D59i3V9=&-7 $ *  F'-- $ =95=9=9 =9  =9~;;9?L 3 3); 3  3?4&..3QT*W*W38*WIN*W *WX.1`h)TD!LjX7$r1)f  rIr\cT\rSrSrSrSrS SjrS SjrS SjrS Sjr Sr g) AsyncWebSocketContextiXz.Helper to enable simpler context manager usage_coro_objcXlSUlgrFrO)rrcoros rJrqAsyncWebSocketContext.__init__^s04 +/ rIc6URR5$rF)rP __await__rs rJrVAsyncWebSocketContext.__await__bszz##%%rIcX# URIShvN UlUR$N7frFrOrs rJr AsyncWebSocketContext.__aenter__es"**$ yy%s *(*cx# UR(a#URR5IShvN ggN7frF)rQr)rrrrtbs rJrAsyncWebSocketContext.__aexit__is* 99))//# # #  #s /:8:N)rSzAwaitable[AsyncWebSocket]rxry)rxz)Generator[object, object, AsyncWebSocket])rxr\)rrIrrJr[rKrxry) rOrPrQrRrSrrqrVrrrUrHrIrJrNrNXsD8!I0&$,$"$  $  $rIrN)rzasyncio.Future[None]rxry)crS __future__rrrrrrrcollections.abcrrr contextlibr dataclassesr r enumr functoolsr jsonr json_dumpsrrZrandomrrtypingrrrrrraiorrconstrrrrr rr!r"utilsr# exceptionsr%r&modelsr'r(r)r*typing_extensionsr+r,r-r r.rr/rr0r1r2r]r3r4r5r ON_DATA_Trw ON_MESSAGE_T ON_ERROR_T ON_OPEN_TrC ON_CLOSE_TtupleRECV_QUEUE_ITEMSEND_QUEUE_ITEMr:rTr<rWrmr}rrrrTr6r\rNrHrIrJrus# ;::($$II/HH"#.88&'"$$OO0 A+uk:D@AI[%#+6<=L; 2D89J+,-I;S1478JE3J'OE:-.O&jZH |H RR R,'.(Y('M' )G)  EEPFG| |~ ]D&$$$rI