+ PV-j+aR t"0tRt^RIt^RIt^RIt^RIHt^RIHtH t H t ^RI H t ^RI Ht^RIHtHt^RIHt^RIHtHtHtHtHtHtHtHt^R IHtHt^t]^kR t !R R 4t!R#)z%WebSocket protocol versions 13 and 8.N)partial)FinalOptionalSet) BaseProtocol)ClientConnectionResetError) ZLibBackendZLibCompressor)DEFAULT_CHUNK_SIZE)MASK_LENMSG_SIZEPACK_CLOSE_CODE PACK_LEN1 PACK_LEN2 PACK_LEN3 PACK_RANDBITSwebsocket_mask)WS_DEFLATE_TRAILING WSMsgTypec a]tRt^'toRtRRR]R]P!4R^RR/V3RlR lltRV3R lR llt V3R lRlt V3RlRlt V3RlRlt V3RlRlt RV3RlRlltRtVtR #)WebSocketWriteraWebSocket writer. The writer is responsible for sending messages to the client. It is created by the protocol when a connection is established. The writer should avoid implementing any application logic and should only be concerned with the low-level details of the WebSocket protocol. use_maskFlimitrandomcompress notakeovercp<V^8dQhRS[RS[PRS[RS[RS[P RS[RS[RR /#) protocol transportrrrrrreturnN)rasyncio TransportboolintrRandom)format __classdict__s"j/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/aiohttp/_websocket/writer.py __annotate__WebSocketWriter.__annotate__0so@@@$$@  @  @ @@@ @c WnW nW0n\VP^ 4VnW`nWpnRVnW@n ^Vn RVn \P!4Vn\4VnR#)zInitialize a WebSocket writer.FN)rrrr getrandbitsget_random_bitsrr_closing_limit _output_size _compressobjr!Lock _send_lockset_background_tasks)selfrrrrrrrs&&&$$$$$r(__init__WebSocketWriter.__init__0se! " &v'9'92> $  6:!,,.:=%r+Nc><V^8dQhRS[RS[RS[R,RR/#rmessageopcoderNr bytesr$)r&r's"r(r)r*Is1040404&)04584Z04 04r+c 8"VP'd)V\P,'g \R4hV'gVP'd V\ 8dVP W^4EM\V4\8:dAVP;_uu_4GRjxL VPWV4RRR4GRjxL M\P!4pVPWV4p\PR8d\P !WTRR7pMVP#V4pVP$P'V4VP)VP$P*4\P,!V4GRjxL VP.VP08dJ^VnVP2P4'd%VP2P74GRjxL R#R#R#ELREL3 +GRjxL 'giL;iLL.5i)z(>(F(F G..+ + +   t{{ * !D }}$$$mm11333% +='* ,4s/HHHA H"G4#H&G:9 HG7CH H AH H)H* H7H:H H H H  HHc0<V^8dQhRS[RS[RS[RR/#)rr<r=rsvr Nr>)r&r's"r(r)r*{s)0505e05S05s05t05r+c `\V4pVPpV'd^M^p^V,V,pV^~8d\WtV,4p^p M4VR8d\V^~V,V4p^p M\ V^V,V4p^ p VP P 4'd \R4hV'dv\VP44p \V4p \W4VP PW,V ,4V;P\, un McV\8d8VP PV4VP PV4M!VP PW,4V;PW,, un R#)z Write a websocket frame to the transport. This method handles frame header construction, masking, and writing to transport. It does not handle compression or flow control - those are the responsibility of the caller. irAN)rIrrrrr is_closingrrr. bytearrayrwriter1r r ) r7r<r=r] msg_lengthrmask_bit first_byteheader header_lenmask message_arrs &&&& r(rH&WebSocketWriter._write_websocket_frame{sI\ ==#4CZ&(  z+@AFJ % z3>:FFJz3>:FFJ >> $ $ & &,-PQ Q  !5!5!78D#G,K 4 - NN !< =    )  ( " NN  ( NN  ) NN !1 2 Z44r+c4<V^8dQhRS[R,RS[/#)rrNr )r$r )r&r's"r(r)r*s!!d !~!r+c V'd"\\PV)\R7#VP'g1\\PVP )\R7VnVP#)zBGet or create a compressor object for the given compression level.)levelwbitsmax_sync_chunk_size)r r Z_BEST_SPEEDrJr2r)r7rs&&r(_get_compressorWebSocketWriter._get_compressorsa !!..i$A     .!..}}n$A!D     r+c><V^8dQhRS[RS[RS[R,RR/#r;r>)r&r's"r(r)r*s1   &) 584Z  r+c VPV4pTPVPV4TPVP'd\ P M\ P4,P\4V^@4R#)z Synchronous send for small compressed frames. This is used for small compressed payloads that compress synchronously in the event loop. Since there are no await points, this is inherently cancellation-safe. N) rprH compress_syncflushrr Z_FULL_FLUSH Z_SYNC_FLUSH removesuffixrr7r<r=r compressobjs&&&& r(rK+WebSocketWriter._send_compressed_frame_syncsu**84  ##))'2## ,,$11 l./   r+c><V^8dQhRS[RS[RS[R,RR/#r;r>)r&r's"r(r)r*s1   &) 584Z   r+c "VP;_uu_4GRjxL VPV4pTPVPV4GRjxL TP VP 'd\ PM\ P4,P\4V^@4RRR4GRjxL R#LLwL +GRjxL 'giR#;i5i)a Async send for large compressed frames with lock. Acquires the lock and compresses large payloads asynchronously in the executor. The lock is held for the entire operation to ensure the compressor state is not corrupted by concurrent sends. MUST be run shielded from cancellation. If cancelled after compression but before sending, the compressor state would be advanced but data not sent, corrupting subsequent frames. N) r4rprHrrurrrvrwrxrrys&&&& r(rM3WebSocketWriter._send_compressed_frame_async_lockeds????..x8K  ' '%..w77!''???$00(55 ,23 #??8#???scC)CC)1C C C 1AC 4 C)?C C)C  C) C& C C& C& C)c:<V^8dQhRS[RS[S[,RR/#)rcoder<r N)r$r?str)r&r's"r(r)r*s& ! ! !US[ !4 !r+c "\V\4'dVPR4pVP\ V4V,\ P R7GRjxL RVnR#L RTni;i5i)zrsZ+ ''(:;(   3'('!*^!^!r+