+ Ȝi:^RIHt^RIt^RIt^RIt^RIt^RIHt^RIH t ^RI H t ^RI H t ^RIHtHt^RIHt^R IHtHtHtHtHtHtHt^R IHtHt^R IHtHtH t H!t!^R I"H#t#H$t$^R I%H&t&^RI'H(t(H)t)^RI*H+t+^RI%H,t,H-t-]'d^RI.H/t/^RIH0t0^RI"H1t1^RI2H3t3^RI4H5t5^RI6H7t7H8t8H9t9^RI:H;t;H]1.R3,t?]R]]>]@3,.R3,tA]R]$.R3,tB]R.R3,tC]R]D]@.R3,tE]F]]>]G3,]D3,tH]F]>]]!]D3,3,tI] !]R(R7t!RR] 4tJ!RR]$4tK!RR ]K](4tL!R!R"]K])4tM!R#R$4tN]R),tO!R%R]N4tP!R&R']N4tQR#)*) annotationsN)Callable)suppress)IntEnum)partial)dumpsloads)select) TYPE_CHECKINGAnyClassVarLiteralOptionalTypeVarUnion)CURL_SOCKET_BAD get_selector) CurlECodeCurlInfoCurlOpt CurlWsFlag)Curl CurlError)CurlCffiWarning) SessionClosedTimeout)Response)not_setset_curl_options)Self)CurlHttpVersion) CurlWsFrame) CookieTypes) HeaderTypes)BrowserTypeLiteralExtraFingerprints ExtraFpDict) AsyncSession ProxySpecT WebSocket) separatorscb]tRt^0tRtRtRtRtRtRt Rt Rt R t R t R tR tR tRtRtRtRtRtRtRtR#) WsCloseCodez?See: https://www.iana.org/assignments/websocket/websocket.xhtmliiiiiiiiiiiiiii i i N)__name__ __module__ __qualname____firstlineno____doc__OK GOING_AWAYPROTOCOL_ERRORUNSUPPORTED_DATAUNKNOWNABNORMAL_CLOSURE INVALID_DATAPOLICY_VIOLATIONMESSAGE_TOO_BIGMANDATORY_EXTENSIONINTERNAL_ERRORSERVICE_RESTARTTRY_AGAIN_LATER BAD_GATEWAY TLS_HANDSHAKE UNAUTHORIZED FORBIDDENTIMEOUT__static_attributes__r0f/Users/mibo/.openclaw/workspace/.venv-ak/lib/python3.14/site-packages/curl_cffi/requests/websockets.pyr.r.0scI BJNGLONOOKMLIGrIr.c6a]tRt^GtRtRRV3RllltRtV;t#)WebSocketErrorzWebSocket-specific error.c V^8dQhRRRR/#)messagestrcodez)Union[WsCloseCode, CurlECode, Literal[0]]r0)formats"rJ __annotate__WebSocketError.__annotate__Js((("K(rIc &<\SV`W4R#N)super__init__)selfrOrQ __class__s&&&rJrXWebSocketError.__init__Js 'rIr0)r)r1r2r3r4r5rXrH __classcell__rZs@rJrLrLGs#(((rIrLc]tRt^PtRtRtR#)WebSocketClosedzWebSocket is already closed.r0Nr1r2r3r4r5rHr0rIrJr_r_Ps&rIr_c]tRt^TtRtRtR#)WebSocketTimeoutzWebSocket operation timed out.r0Nr`r0rIrJrbrbTs(rIrbc]tRt^XtRtRRRR/RRllt]R4t]RR l4t]R R l4t ] R R l4t ] RRl4t Rt RtR#) BaseWebSocket autoclosedebugTFc$V^8dQhRRRRRR/#)rNcurlrreboolrfr0)rRs"rJrSBaseWebSocket.__annotate__bs!TTrIc TWnW nRVnRVnW0nRVnR#)NF_curlre _close_code _close_reasonrfclosed)rYrhrerfs&&$$rJrXBaseWebSocket.__init__bs( (*.,0  rIc xVP\Jd\VPR7VnVP#))rf)rmrrrfrYs&rJrhBaseWebSocket.curljs( :: DJJ/DJzzrIcV^8dQhRR/#)rNreturnz Optional[int]r0)rRs"rJrSrjqs  M rIc VP#)zThe WebSocket close reason, if the connection has been closed.)rorss&rJ close_reasonBaseWebSocket.close_reasonus!!!rIc$V^8dQhRRRRRR/#)rNrQintreasonbytesrvr0)rRs"rJrSrj{s!000U0u0rIc >\P!RV4V,#)!H)structpack)rQrs&&rJ_pack_close_frameBaseWebSocket._pack_close_framezs{{4&//rIc V^8dQhRRRR/#)rNframerrvztuple[int, str]r0)rRs"rJrSrjs5_rIc \V4^8d\PpRpW3#\P!RV4^,pVR,P 4pV\P8XgVR8gVR8d\ RV 2\P4hW3# \d!p\ R\P4ThRp?i\d!p\ R \P4ThRp?ii;i) rNr:rNNNr/izInvalid close code: zInvalid close messageNzInvalid close frame) lenr.r:r unpack_fromdecoderLr8UnicodeDecodeErrorr< Exception)rrQres& rJ_unpack_close_frame!BaseWebSocket._unpack_close_frame~s u:>&&DF$|! ))$6q9r))+;...$+(.tf5{7Q7QBN|& $+[-E-E $);+E+E s)5B C4+C C4C4C//C4c HRVnVPP4R#)z$Terminate the underlying connection.TN)rprhcloserss&rJ terminateBaseWebSocket.terminates  rI)rnrormrerprfNrl)r1r2r3r4 __slots__rXpropertyrhrxr} staticmethodrrrrHr0rIrJrdrdXsIE   ""00.rIrdca]tRt^tRtR5t]3RRRRRRRRR RR RR RR R/R V3RlllltRRltRRlt RRlt RRRR]R^RRRRRRRRRRRRRRR^R3RRllt RRlt RRlt RRltR]/R R!llt]P$3R"R#lltR$R%ltR&R'ltR(R)ltR*]/R+R,lltR-R.ltR6R/R0llt]P8R13R2R3lltR4tV;t#)7r+z)A WebSocket implementation using libcurl.skip_utf8_validationreTFrfon_openNon_closeon_data on_messageon_errorc<V^8dQhRRRRRRRRRRR R R R R RRR/ #)rNrhzUnion[Curl, Any]rerirrfrzOptional[ON_OPEN_T]rzOptional[ON_CLOSE_T]rzOptional[ON_DATA_T]rzOptional[ON_MESSAGE_T]rzOptional[ON_ERROR_T]r0)rRs"rJrSWebSocket.__annotate__sd(/(/(/ (/ # (/  (/%(/'(/%(/+(/'(/rIc 2<\S V`WVR7W0nRVn/VnV'dWPPR&V'dW`PR&V'dWpPR&V'dWPR&V 'dWPR&R#R#) 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)`` rhrerfFopenrdatarOerrorN)rWrXr keep_running _emitters) rYrhrerrfrrrrrrZs &&$$$$$$$$rJrXWebSocket.__init__s|4 duE$8!!;= %,NN6 " &.NN7 # %,NN6 " (2NN9 % &.NN7 # rIcV^8dQhRR/#)rNrvr+r0)rRs"rJrSrs)rIc @VP'd \R4hV#)WebSocket is closedrpr_rss&rJ__iter__WebSocket.__iter__s ;;;!"78 8 rIcV^8dQhRR/#rNrvrr0)rRs"rJrSrs%rIc pVP4wrV\P,'d\hV#rV)recvrCLOSE StopIterationrYmsgflagss& rJ__next__WebSocket.__next__s+YY[  :## # #  rIc V^8dQhRRRR/#)rN event_typeEventTypeLiteralrvNoner0)rRs"rJrSrs 0DrIc <VPPV4pV'dV!V.VO5!R#R# \d^pTPPR4pT'dT!Y4Rp?R#\P!RT R2\ ^R7Rp?R#Rp?ii;i)rzWebSocket callback 'z' failed stacklevelN)rgetrwarningswarnr)rYrargscallbackrerror_callbacks&&* rJ_emitWebSocket._emits>>%%j1  %%  !%!3!3G!<!"4++MM.zl(C'#$ s 3 B+B/!BBzgzip, deflate, brrc2|V^8dQhRRRRRRRRR R R R R RRRRRRRRR RRRRRRRRRRRRRRR RR!R"R#R$R%RR&R'R(RR)R*/#)+rNurlrPparamsz"Optional[Union[dict, list, tuple]]headerszOptional[HeaderTypes]cookieszOptional[CookieTypes]authzOptional[tuple[str, str]]timeoutz3Optional[Union[float, tuple[float, float], object]]allow_redirectsri max_redirectsrproxieszOptional[ProxySpec]proxyr{ proxy_authverifyzOptional[bool]refereraccept_encoding impersonatezOptional[BrowserTypeLiteral]ja3akamaiextra_fpz/Optional[Union[ExtraFingerprints, ExtraFpDict]]default_headersquotezUnion[str, Literal[False]] http_versionzOptional[CurlHttpVersion] interfacecertz%Optional[Union[str, tuple[str, str]]]max_recv_speed curl_optionszOptional[dict[CurlOpt, str]]r0)rRs"rJrSrs!kk k3k' k ' k ( kEkkk%kk.kkk'k 2!k"#k$%k&B'k()k**+k,0-k.!/k041k23k435krIc FVPp\R/RVbRRbRVbRRV.bRRV.bRRV.bR VbR VbR VbR VbR RV .bRV bRV bRRV .bRV bRVbRVbRVbRVbRVbRVbRVbRVbRVbRVbRVbRVbVP\P^4VP 4V#)a_Connect 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. 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. 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 response content if charset is not found in headers. Defaults to "utf-8". Can be set to a callable for automatic detection. quote: Set characters to be quoted, i.e. percent-encoded. Default safe string is ``!#$%&'()*+,/:;=?@[]~``. If set to a sting, the character will be removed from the safe string, thus quoted. If set to False, the url will be kept as is, without any automatic percent-encoding, you must encode the URL yourself. curl_options: extra curl options to use. 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. rhmethodGETr params_listN headers_list cookies_listrrrr proxies_listrr verify_listrrrrrrrrrrrrrr0)rhrsetoptr CONNECT_ONLYperform)rYrrrrrrrrrrrrrrrrrrrrrrrrrrhs&&&&&&&&&&&&&&&&&&&&&&&&&& rJconnectWebSocket.connectsXPyy    v        , (   " v  ,! "$# $% &' () *,+ ,- .&/ 0 1 2*3 45 6&7 > G((!,  rIcV^8dQhRR/#)rNrvztuple[bytes, CurlWsFrame]r0)rRs"rJrSrZs8rIc VP'd \R4hVPP4wrVP\ P ,'dBVPV4wVnVn TP'dTP4W3# \d3pTPTnTPTP4hRp?ii;i)z2Receive a single curl websocket fragment as bytes.WebSocket is already closedN)rpr_rhws_recvrrrrrnrorLrQrre)rYchunkrrs& rJ recv_fragmentWebSocket.recv_fragmentZs ;;;!"?@ @yy((*  ;;)) ) ) 7;7O7OPU7V4 $"4~~~ |" $%66  166"  s"B%% C"0-CC"cV^8dQhRR/#)rNrvztuple[bytes, int]r0)rRs"rJrSrps''''rIc *.p^pVPP\P4pV\8Xd\ R\ P4hVP4wrEVPpVPV4VP^8Xd V\P,^8XdMKaKcRP%V4V3# \d?pTP\ P 8Xd\#T...R4wpRp?KhRp?ii;i)zs Receive a frame as bytes. libcurl splits frames into fragments, so we have to collect all the chunks for a frame. Invalid active socket?NrI)rhgetinfor ACTIVESOCKETrrLrNO_CONNECTION_AVAILABLErrappend bytesleftrCONTrrQAGAINr join)rYchunksrsock_fdrrr_s& rJrWebSocket.recvps ))##H$9$9: o % ')J)J  #113   e$??a'EJOO,Cq,H-I'xx&& 66Y__,%gYBiik  '' !79Q9QR R{{}rIr c V^8dQhRRRR/#)rNr zCallable[[str], T]rvr*r0)rRs"rJrSrs"4rIc 2VP4pV!V4#)zMReceive a JSON frame. Args: loads: JSON decoder, default is json.loads. )r)rYr rs&$ rJ recv_jsonWebSocket.recv_jsons }}T{rIc V^8dQhRRRR/#)rNpayloadzUnion[str, bytes, memoryview]rrr0)rRs"rJrSrs--.--rIc V\P,'dRVnVP'd \ R4h\ V\ 4'dVP4pVPP\P4pV\8Xd\R\P4h^pV\!V48d+WRpVPP#WR4pYF, pK:V# \$dRpTP&\P(8Xd-\+.T..R4wrpT 'g \R4ThRp?KhRp?ii;i)zUSend a data frame. Args: payload: data to send. flags: flags for the frame. FrrNrzSocket write timeout)rrrrpr_ isinstancerPencoderhrrrrrLrrrws_sendrrQrr ) rYrrroffsetcurrent_buffern_sentrr  writeables &&& rJsendWebSocket.sends :## # # %D  ;;;!"?@ @ gs # #nn&G))##H$9$9: o % ')J)J  s7|#$W-N **>A  F  66Y__,&,R'B&DOA!$,-CD!K  s C44 E?AE  E  EcV^8dQhRR/#rNrrr0)rRs"rJrSrs5555rIc BVPV\P4#)z>Send a binary frame. Args: payload: binary data to send. rrBINARYrYrs&&rJ send_binaryWebSocket.send_binary yy*"3"344rIcV^8dQhRR/#r!r0)rRs"rJrSrs55%5rIc BVPV\P4#)z\Send a binary frame, alias of :meth:`send_binary`. Args: payload: binary data to send. r#r%s&&rJ send_bytesWebSocket.send_bytesr(rIcV^8dQhRR/#)rNrrPr0)rRs"rJrSrs333rIc BVPV\P4#)z:Send a text frame. Args: payload: text data to send. rrr r%s&&rJsend_strWebSocket.send_str yy*//22rIrc V^8dQhRRRR/#)rNrr rCallable[[Any], str]r0)rRs"rJrSrs---0D-rIc 0VPV!V44#)zeSend a JSON frame. Args: payload: data to send. dumps: JSON encoder, default is json.dumps. r0rYrrs&&$rJ send_jsonWebSocket.send_jsons}}U7^,,rIcV^8dQhRR/#rNrzUnion[str, bytes]r0)rRs"rJrSrs33-3rIc BVPV\P4#)z5Send a ping frame. Args: payload: data to send. rrPINGr%s&&rJpingWebSocket.pingr2rIcV^8dQhRR/#)rNrrPr0)rRs"rJrSrsBBsBrIc jV'dVP!V3/VBVPP\P4pV\ 8Xd\ R\P4hVPR4.pRVn VP'EdVP4wrVVPpVPRWV4VPV4VP^8XdV\P ,^8XgKRVP"9dRP%V4pV\P&,'d$VP('gVP+4pV\P6,'gV\P&,'dVPRV4.pV\P8,'dFR Vn TPR VP2;'g^VP:;'gR 4EKEKR# \,dUp \.P0TnTP5\.P04\ R\.P04T hRp ? ii;i \<dp T P>\P@8Xd\CT...R 4wp Rp ? EKATPR T 4TPD'gD\.PFp \IT \ 4'd T P>p TP5T 4hRp ? ii;i)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 rrTrrOrIz Invalid UTF-8NFrrrr)%rrhrrrrrLrrrrrrrrrrrrr rrrr.r<rnrr$rrorrQrr rpr:r) rYrkwargsrrrrrrrr rQs &&, rJ run_foreverWebSocket.run_foreversi  LL ' '))##H$9$9: o % ')J)J  6 + #113   650 e$1,1HA1M.((6*C //9R9R9R%"%**,C 1 111uz7N7N 9c2:++++(-D%JJw(8(8(=(=At?Q?Q?W?WUWX,= $ 2%/:/G/GD, JJ{'?'?@"0 /1I1I##$%%  66Y__,$gYBJJH*JJ$0J%J;JJ I>*AI99I>>J L2 2L-#L-)AL--L2rIc V^8dQhRRRR/#)rNrQrrOrr0)rRs"rJrSr<s#rIc VP\JdR#VPW4pVPV\P 4VP 4R#)zNClose the connection. Args: code: close code. message: close reason. N)rhrrrrrr)rYrQrOrs&&& rJrWebSocket.close<sC 99  $$T3 #z''( rI)rnrorrr)rrr)r) r1r2r3r4r5rrrXrrrrrrrr rrr$rr&r+r0rr8r?rDr.r6rrHr\r]s@rJr+r+s63I")(/ (/ &+ (/  (/(,(/*.(/(,(/.2(/*.(/(/T  &6:)-)-*.GN $'+#04!%!%)<48! $DH $,.26#'6:595kZ,'@u'---^553-u-3BH!,rIc.a]tRtRt$RtRRtRtR]R&^tR]R&Rt R ]R &R R R RRRRRRRRRRRRRRRR^?/ RV3Rlllt ] RRl4t ] RRl4t RR ltR!R"ltR#R$ltR%R&ltR'R(ltR)R*/R+R,lltR)R*/R-R.lltR/]R)R*/R0R1llt]P03R2R3lltR4R5ltR6R7ltR8R9ltR:]/R;R<lltR=R>lt] PBR?R@3RARBllt"RCV3RDllt#RERFlt$RGRHlt%RIRJlt&RSRKRLllt'RMV3RNllt(RORPlt)RQt*V;t+#)TAsyncWebSocketiNz An asyncio WebSocket implementation using libcurl. NOTE: This object represents a single WebSocket connection. Once closed, it cannot be reopened. A new instance must be created to reconnect. retry_on_recv_erroriz ClassVar[int]_MAX_CURL_FRAME_SIZE_MAX_RECV_RETRIESg333333?zClassVar[float]_RECV_RETRY_DELAYreTrfFrecv_queue_sizeisend_queue_sizemax_send_batch_sizecoalesce_framesyield_intervalgMbP?fair_scheduling yield_maskcLV^8dQhRRRRRRRRRR R R R R R RR RRRRRRR RR/ #)rNsessionr(rhrrerirfrOrrPrRrSrKrTfloatrUrVrvrr0)rRs"rJrSAsyncWebSocket.__annotate__qsL'L'L'L'  L'  L'L'L'!L'L'"L'L'L'L' L'rIc  <\S V`W#VR7WnRVnRVn\ P !4Vn\P !4Vn \ P!4Vn RVn RVn RVn\ P!VR7Vn\ P!VR7VnWpnWnWnWnWnWn^VnRVnR#)akInitializes an Async WebSocket session. This class should not be instantiated directly. It is intended to be created via the `AsyncSession.ws_connect()` method, which correctly handles setup and initialization of the underlying I/O tasks. Important: This WebSocket implementation uses a decoupled I/O model. Network operations occur in background tasks. As a result, network-related errors that occur during a `send()` operation will not be raised by `send()`. Instead, they are placed into the receive queue and will be raised by the next call to `recv()`. Args: session (AsyncSession): An instantiated AsyncSession object. curl (Curl): The underlying Curl to use. autoclose (bool, optional): Close the WS on receiving a close frame. debug (bool, optional): Enable debug messages. Defaults to False. recv_queue_size (int, optional): The maximum number of incoming WebSocket messages to buffer internally. This queue stores messages received by the Curl socket that are waiting to be consumed by calling `recv()` send_queue_size (int, optional): The maximum number of outgoing WebSocket messages to buffer before applying network backpressure. When you call `send(...)` the message is placed in this queue and transmitted when the Curl socket is next available for sending. max_send_batch_size (int, optional): The max number of messages per batch. coalesce_frames (bool, optional): Combine multiple frames into a batch. retry_on_recv_error (bool, optional): Retry recv on some transient errors. yield_interval (float, optional): How often to yield control in seconds. fair_scheduling (bool, optional): Change the ~5:1 ratio in favor of `recv`:`send` to a fairer 1:1 ratio. This decreases recv throughput. yield_mask (int, optional): A bitmask that sets the yield frequency for cooperative multitasking, checked every `yield_mask + 1` operations. Must be a power of two minus one (e.g., `63`, `127`, `255`) for efficient bitwise checks. Lower values increase fairness; higher values increase throughput. rN)maxsizeF)rWrXrX_loop_sock_fdasyncioLock _close_lock threading_terminate_lockEvent_terminated_event _read_task _write_task _close_handleQueue_receive_queue _send_queue_max_send_batch_size_coalesce_framesrK_yield_interval_use_fair_scheduling _yield_mask_recv_error_retries _terminated)rYrXrhrerfrOrPrRrSrKrTrUrVrZs&&&$$$$$$$$$$rJrXAsyncWebSocket.__init__qsj duE/6 :>  )0/8~~/?07 8<9=7;>Emm#? &>&@ADJzzrIcV^8dQhRR/#)rNrvrr0)rRs"rJrSrZs(((rIc 6VPP4#)z6Returns the current number of items in the send queue.)rlqsizerss&rJrPAsyncWebSocket.send_queue_sizes%%''rIcV^8dQhRR/#)rNrvrir0)rRs"rJrSrZsBB$BrIc VP'gVP'dR#VP'd#VPP4'dR#VP;'dVPP4'*#)a\ 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)rprsrgdonerhrss&rJis_aliveAsyncWebSocket.is_alives_ ;;;$*** ???t3355$$@@)9)9)>)>)@AArIcV^8dQhRR/#rNrvrr0)rRs"rJrSrZs   rIc \VRR4'dR#\\4;_uu_4\P!RV: R2\ ^R7RRR4R# +'giR#;i)z1Warn if the user forgets to close the connection.rpTNzUnclosed WebSocket zN was garbage collected. Always call await ws.close() to ensure clean shutdown.r)getattrrrrrResourceWarningrss&rJ__del__AsyncWebSocket.__del__sU 44 ( (  i MM%dX.II  ! s #A A+ cV^8dQhRR/#)rNrvr r0)rRs"rJrSrZs4rIc @VP'd \R4hV#)zWebSocket has been closedrrss&rJ __aiter__AsyncWebSocket.__aiter__s ;;;!"=> > rIcV^8dQhRR/#rr0)rRs"rJrSrZsrIc "VP4GRjxL wrVeV\P,'d\hV#L/5irV)rrrStopAsyncIterationrs& rJ __anext__AsyncWebSocket.__anext__s:99;&  KUZ%5%555$ $ 'sAA&A AcV^8dQhRR/#rr0)rRs"rJrSrZs   rIc VPeR#VPP\P4VnVP \ 8Xd\R\PR7hR\V4R 2pVPPVP4V R2R7VnVPPVP4V R2R7VnR#) zStart the read/write I/O loop tasks. 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. NzInvalid active socket.)rQz WebSocket-z#xz-read)namez-write)rgrhrrrr_rrLrridrx create_task _read_loop _write_looprh)rYws_ids& rJ_start_io_tasksAsyncWebSocket._start_io_taskss ?? &  ))(*?*?@ ==O + (y/P/P  ""T(2/))//0A5'QV/X9900    wf%51 rIrNc V^8dQhRRRR/#)rNrOptional[float]rvztuple[Optional[bytes], int]r0)rRs"rJrSrZs"")" $"rIc "VP'd,VPP4'd \R4h\P !VPP 4V4GRjxL wr#\V\4'dVhW#3#L! \Pd!p\R\P4ThRp?ii;i5i)aBReceive a frame as bytes. This method waits for and returns the next complete data frame from the receive queue. Args: timeout: how many seconds to wait before giving up. Raises: WebSocketClosed: If `recv()` is called on a closed connection after the receive queue is empty. WebSocketTimeout: If the operation times out. WebSocketError: A protocol or network error that occurred in a background I/O task, including errors from previous `send()` operations. Returns: tuple[bytes, int]: A tuple with the received payload and flags. rNzWebSocket recv() timed out) rprkemptyr_r`wait_forrrr TimeoutErrorrbrOPERATION_TIMEDOUT)rYrresultrrs&$ rJrAsyncWebSocket.recvs, ;;;4..4466!"78 8 ")"2"243F3F3J3J3Lg"VVMF&),, = W ## ",i.J.J  s@2C C2B3B4 BCBC ,CC  Cc V^8dQhRRRR/#)rNrrrvrPr0)rRs"rJrSrZ8sCrIc <"VPVR7GRjxL wr#VeV\P,'g\R\P 4hVP R4#LS \d!p\R\P 4ThRp?ii;i5i)zUReceive a text frame. Args: timeout: how many seconds to wait before giving up. rNzNot a valid text frameutf-8zInvalid UTF-8 in text frame)rrr rLr.r<rr)rYrrrrs&$ rJrAsyncWebSocket.recv_str8s !IIgI66  <  7 7 !9;;S;ST T ;;w' ' 7 "  -{/G/G  s9BA,&BBA.+B. B9BBBr c$V^8dQhRRRRRR/#)rNr z Callable[[Union[str, bytes]], T]rrrvr*r0)rRs"rJrSrZHs*0!  rIc X"VPVR7GRjxL wr4Vf\R\P4hV\P ,'dV!VP R44#V!V4#La \d!p\R\P4ThRp?ii;i5i)zReceive a JSON frame. Args: loads: JSON decoder, default is json.loads. timeout: how many seconds to wait before giving up. rNz(Received empty frame, cannot decode JSONrz Invalid UTF-8 in JSON text frame)rrLr.r<rr rr)rYr rrrrs&$$ rJrAsyncWebSocket.recv_jsonHs!IIgI66  < :K2222s $"$cV^8dQhRR/#r;r0)rRs"rJrSrZs99"39rIc ^"VPV\P4GRjxL #L5i)zgSend a ping frame. Args: payload: data to send. For more info, see the docstring for `send(...)` Nr=r%s&&rJr?AsyncWebSocket.pingrrrIg@c(V^8dQhRRRRRRRR/#) rNrQrrOrrrYrvrr0)rRs"rJrSrZs2%S%S%S38%SIN%S %SrIc h"VP;_uu_4GRjxL VP'dRRR4GRjxL R#RVnVP'dVPP4'gVP W4p\ \ P4;_uu_4\ P!VPPV\P34VR7GRjxL RRR4\ \\4;_uu_4VPV4GRjxL RRR4VP!4\ \ P4;_uu_4\ P!VP"P%4V4GRjxL RRR4RRR4GRjxL R#ELELL +'giL;iL +'giL;iLN +'giLT;i TP!4\ \ P4;_uu_4\ P!TP"P%4T4GRjxL RRR4i +'gii;i;iL +GRjxL 'giR#;i5i)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. This is the recommended way to close the session. Args: code (int, optional): Close code. Defaults to `WsCloseCode.OK`. message (bytes, optional): Close reason. Defaults to `b""`. timeout (float, optional): How long in seconds to wait closed. NTr)rbrprhrrrr`rrrlrrrrbrLflushrrfwait)rYrQrOr close_frames&&&& rJrAsyncWebSocket.closes####{{{$##DK S###D,<,<,A,A,C,C"&"8"8"GK!'"6"677%.. ,,00+z?O?O1PQ$+8 ""2NCC"jj111D g2233!**4+A+A+F+F+H'RRR4+$##87 2DCS43 g2233!**4+A+A+F+F+H'RRR4333+$###s,J2GJ2J J2GJ2J H H ?2H 1AG 6G 7G ;$H G! 4G 5G! 9H 1J23G6 %G4 &G6 *J2 J2=J>J2J2 G G H G! ! G1 ,H 4G6 6 H J 2J;3I= .I1/I= 4 J= J JJJ2J/ J J/ 'J/ ) J2cV^8dQhRR/#rr0)rRs"rJrSrZs1141rIc D<aSP;_uu_4SP'd RRR4R#RSnSP'dFSPP 4'd&SPP V3Rl4SnMq\SS`!4SP'dRSPP'g6SPPR4SPP4RRR4R# +'giR#;i)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. NTcV<SPPSP44#rV)rxr_terminate_helperrssrJ*AsyncWebSocket.terminate..sDII11$2H2H2JKrI)rdrsr^rx is_runningcall_soon_threadsaferirWrrX_closed push_curlrfset)rYrZsfrJrAsyncWebSocket.terminates ! ! !" ! $D zzzdii2244%)YY%C%CK&" !#<<< (<(<(<LL**40**..0#" ! ! !s#DDD.A D5D D cV^8dQhRR/#rr0)rRs"rJrSrZsBMBM$BMrIc D"VPPpVPPpVPPpVP pVP pVPpVPp.p^p VP'EgSVP4p VPVPV PR4T GRjxL TPR8wdTP/TP4TP14p T!4wrTP2pTP4^8d^TnT\6P8,'d\\ P"4;_uu_4T!Y34RRR4TP;T 4GRjxL \\ P"4;_uu_4T!\-R4^34RRR4R#TP=T 4TP>^8:dIT\6P@,^8Xd-RPCT4pTPE4T!TT34T ^, p Y,^8HpTP14T , T8pT'dT'g T'dIMT'd=T'd2\ PF!^4GRjxL TP14p EKEKEKEK\\ P"4;_uu_4V!\-R4^34RRR4R# \dp \\ P"4;_uu_4T!\%RT 2\&P(4^34RRR4M +'giM;iTP+4Rp ? \\ P"4;_uu_4T!\-R4^34RRR4R# +'giR#;iRp ? ii;iEL1 TPR8wdTP/TP4ii;i +'giEL;iEL +'giR#;i \ P"dT!TT34GRjxL EL9i;iEL \HEdpTPJ\&PL8XdRp?EKFTPJ\&PN8XdTPP'dvTP4TPR8d[T;P4^, un\ PF!TPTTP4,4GRjxL Rp?EKZ\\ P"4;_uu_4T!T^34RRR4M +'giM;iTP+4Rp?\\ P"4;_uu_4T!\-R4^34RRR4R# +'giR#;iRp?ii;i \ PVdELU\dvpTP'gI\\ P"4;_uu_4T!T^34RRR4M +'giM;iTP+4Rp?ELRp?ii;i +'giR#;i \\ P"4;_uu_4T!\-R4^34RRR4i +'gii;i;i5i)a#The main asynchronous task for reading incoming WebSocket frames. This method is fully event-driven. 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. To ensure cooperative multitasking during high-volume message streams, the loop yields control to the asyncio event loop periodically. 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, even though the defaults are generous and should be suitable for most use cases. Nzadd_reader failed: zConnection closed.rIr]),rmrrkrrrxrprqrorp create_future add_readerr_ set_resultrrr`rrLrrrr_ remove_readertimerrrrr_handle_close_framerrrrclearsleeprrQr RECV_ERRORrKrMrNCancelledError)rY curl_ws_recvqueue_put_nowait queue_putrxrUrVrTr msg_counter read_futureexc start_timerrrrOop_check time_checkrs& rJrAsyncWebSocket._read_loopsK&zz)) ..99''++ yy33%% --  e Mkkk"002 OODMM;3I3I4P:%%%}}***4==9"YY[ :'3~ %*[[33a778D4!:#3#333!)'*;*;!R ?R X[ !\ Z7 \  O9*!O4 &M:1 O4: N O4X!!\ O  \  O1 + \ 4O99X<O??/P..X1 Q < R Q  \ "R>R?RRRR XX9X0X1A(XUXX&!X V X V+ &X>X!\ #X7 \  X \ XXZ42[ 5Z4>Z4?3Z/2 Z= Z/ Z Z/)[ /Z44[ 7 [  \  "\-\  \ \ \\ cV^8dQhRR/#rr0)rRs"rJrSrZsZ!Z!4Z!rIc p "\P\P,pVPpVPP pVPP pV!4GRjxL wrVWV3.pV\P,'gW\V4VP8d=V!4wrXVPWX34V\P,'dMKVVP'Ed/p VEFWwrXW,'Ed"V P4FwrV!RPV 4V 4GRjxL 'dK-\\V44Fp VPP!4K VP"'gVP%4R#R# V P'4V!WX4GRjxL 'g]\\V44Fp VPP!4K VP"'gVP%4R#R#EK6V P)V.4PV4EKZ V P4FwrV!RPV 4V 4GRjxL 'dK-\\V44Fp VPP!4K VP"'gVP%4R#R# M}VFwwrXV!WX4GRjxL 'dK\\V44Fp VPP!4K VP"'gVP%4R#R# \\V44Fp VPP!4K VR,^,\P,'gEKyTP"'gTP%4R#R#EL \PdEK3i;iELELVELEL \\T44Fp TPP!4K i;i \P*dL\,dp TP"'gg\/\P04;_uu_4TP2P5T ^34RRR4Rp ? EK +'giRp ? EL";iRp ? EL+Rp ? ii;i TP"'gTP%4ii;i5i)a The high-level send manager. It efficiently gathers pending messages from the send queue and orchestrates their transmission. This method runs a continuous loop that consumes messages from the `_send_queue`. To improve performance and reduce system call overhead, it implements an adaptive batching strategy. It greedily gathers multiple pending messages from the queue and then coalesces the payloads of messages that share the same flags (e.g., all text frames) into a single, larger payload, ONLY if `coalesce_frames=True` and the frame is not a CONTROL frame, as the spec requires them to be whole. It will batch as many as possible, then iterate over the batch and send the frames, one at a time. This batching and coalescing significantly improves throughput for high volumes of small messages where the message boundaries do not matter. The final, consolidated payloads are then passed to the `_send_payload` method for transmission. NrIr])rrr> _send_payloadrlr get_nowaitrrmrr` QueueEmptyrnitemsrrange task_donerprr setdefaultrrrrrkr)rYcontrol_frame_flags send_payload queue_getqueue_get_nowaitrrbatchrdata_to_coalesce frame_grouppayloadsr rs& rJrAsyncWebSocket._write_loops&$.#3#3joo#E)) $$(( ++66B !'0{!2")*z////e*t'@'@@"-=-?NG!LL')9:$z'7'777 % 8 5,,,CE(.3NG$::=M=S=S=U$9K1=(+(:K2&,&,&,&)/(#3u:.((224/";;; S>V !1 6 6 8-9'-I'I'I$* #3u:.((224/";;; E(J!1 ; ;E2 F M Mg V/4 6F5K5K5M1K)5chhx6H+)V#V#V#V &#3u:.((224/";;; 96N /4NG)5g)E#E#E#E &#3u:.((224/";;; //4 #3u:.((224/9Q<*"2"222;;; "3 '11"!",& (J$W $F #3u:.((224/%%   ;;;;g//00''22Aq6:10000 ;;;; s~AT6! Q',P-AQ'/8P'Q'+P->A P-P!P-P-5Q' &T61P-P$ P-P-5Q'&T65AP-P'P-P-5Q'&T67P- P* P-P-5Q'&T65P-7AQ'T&T6Q'PQ'PQ'!P-$P-'P-*P--7Q$$Q''T <T>T T 3T;S(T!T( S= 3T7T=TTT  T%T33T6c$V^8dQhRRRRRR/#)rNrrrrrvrir0)rRs"rJrSrZs&MM5MMMrIc N"VPPpVPPpVPp\ V4p^p^pVP 4p V\V48dWP,^8Xg'VP 4V , VP8d/\P!^4GRjxL VP 4p WgWpP,p V!W4p V ^8XdO\\P4;_uu_4V!\R\ P"4^34RRR4R#W{, pV^, pEKR#L +'giR#;i \$Edp T P&\ P(8wdO\\P4;_uu_4T!T ^34RRR4M +'giM;iRp ? R#TP+4p TP-TP.T P0R4M \2dsp\\P4;_uu_4T!\RT 2\ P44^34RRR4M +'giM;iRp?Rp ? R#Rp?ii;iT GRjxL TP.R8wd#TP7TP.4Rp ? EKRp ? EK TP.R8wdTP7TP.4ii;iRp ? ii;i5i)a< The low-level I/O Handler. It transmits a single payload, handling fragmentation, backpressure (EAGAIN), and cooperative multitasking. Returns False on a non-recoverable error. Args: payload: The complete byte payload to be sent. flags: The `CurlWsFlag` indicating the frame type (e.g., `TEXT`, `BINARY`). Nzws_send returned 0 bytesFzadd_writer failed: Tr])rmrrkrrxrrrrqror`rrLrrrLr SEND_ERRORrrQrr add_writerr_rrr remove_writer)rYrr curl_ws_sendrrxviewr write_opsrrrr write_futurers&&& rJrAsyncWebSocket._send_payloadsvzz)) ..99yy'"  IIK s4y ,,,2 j($$7%mmA&&&!YY[ / :f/H/H&HI%e3Q;!'"3"344( .$>$-$8$8!"!" 5! Q @g'54! :66Y__,!'"3"344(!Q05444  $113  !OODMM<3J3JDQ !!'"3"344( .&9#$?$-$E$E!"!" 5444!5 !:&&&}}***4==99+t}}***4==9+9 :sB>L%EL%AE3#E=E3L%E3L% E0 *E3.L%0E33 L"?AL? G L G# L&L%,L='H%$L% J"0!J&J 7 J J JLL%J""L&K++J.,K+1,LL%+/LLL""L%c V^8dQhRRRR/#)rNrrrvrr0)rRs"rJrSrZ=sXX?XdXrIc "VP'dLVPP4'd,VPP4'g \ R4h\ P !VPP4VR7GRjxL R#L \ Pdp\R4ThRp?ii;i5i)aOWaits 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 (Optional[float], 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. z6Cannot flush, writer task has terminated unexpectedly.rNz*Timed out waiting for send queue to flush.) rhrrlrrLr`rrrrb)rYrrs&& rJrAsyncWebSocket.flush=s$      %%''$$**,, H  X""4#3#3#8#8#:GL L L## X"#OPVW W XsF2CC C!3BBBCBC2 B>>CCcV^8dQhRR/#rr0)rRs"rJrSrZ\s/)/)/)rIc <"\4p^pVPVP3FGpV'd<VP4'g$VP 4VP V4KEKGKI V'd_\\ P4;_uu_4\ P!\ P!VRR/VR7GRjxL RRR4VPP4'g8VPP4VPP!4KWVP&R8wd\\(4;_uu_4VP*P-VP&4RRR4\\(4;_uu_4VP*P/VP&4RRR4RVn\0SV`e4VP4'd8VP4P6'gVP4P9R4VP:P4R# \ P\3dEK<i;iEL +'giEL;i \ P"\$3dEKni;i +'giEL-;i +'giL;i TP:P4i;i5i)z)Utility method for connection terminationreturn_exceptionsTrNr])rrgrhrcanceladdr`r RuntimeErrorrrrgatherrlrrrr ValueErrorr_rrxrrrWrrXrrrf)rYtasks_to_cancel max_timeoutio_taskrZs& rJr AsyncWebSocket._terminate_helper\s 365 * ) OOT-=-=>w||~~('++G4(6w?g2233!**P4P +4&&,,..$$//1$$..0 }}"i((II++DMM:)i((II++DMM:)DM G  |||DLL$8$8$8 &&t,  " " & & (G .. = 433 **J7 )((((  " " & & (s K)K I !I,K TPVP;'g\P4GRjxL R#VP4R# \dpTPTnRp?LRp?ii;iLA5i)z>>$+++**T--??@ @ @ NN  & vvD   & AsJCBCCC$C<B>=C B; B61C6B;;C)rnrirbrornr^rmrgrkrrrlr_rdrsrfrprhrorqrprKrX)rXr^r_rbrdrgrhrirkrlrmrnrKrorprqrrrsrfrV),r1r2r3r4r5rrL__annotations__rMrNrXrrxrPrrrrrrrr rrr$rr&r+r0rr8r?r.r6rrrrrrrrrHr\r]s@rJrJrJNsI.+0-/'(}(),,L'  L'  L' #L' #L'$'L'!&L'%*L'!&L'!&L'L'L'\ ((B&    :",0"H4 38$( :'--.9`;;9 3=B 39&..3QT%SN11@BMHZ!xM^X>/)/)b  rIrJ),:)rrrrOr)R __future__rr`rrcrcollections.abcr contextlibrenumr functoolsrjsonrr r typingr r r rrrraiorrconstrrrrrhrrutilsr exceptionsrrmodelsrrrtyping_extensionsr r!r"rr#rr$rr%r&r'rXr(r)r*r ON_DATA_TrP ON_MESSAGE_T ON_ERROR_T ON_OPEN_Tr ON_CLOSE_TtuplerRECV_QUEUE_ITEMSEND_QUEUE_ITEMr.rLr_rbrdrr+rJr0rIrJr7s" $RRR/<<"#.,&'"$$OO0 A+uk:D@AI[%s *;