+ i:2^RIHt^RIt^RIt^RIt^RIHtHtHtH t H t H t ^RI H t ^RIHtHtHtHt^RIHt^RIHtR.t]P.!R 4t!R R4tR#) ) annotationsN)AnyCallableIterableIteratorLiteraloverload)ConcurrencyError) OP_BINARYOP_CONTOP_TEXTFrame)Data)Deadline Assemblerzutf-8cb]tRt^tRtRRRR3RRlltR(RRlltR R lt]R R l4t ]R Rl4t ]R(RRll4t ]R(RRll4t ]R)RRll4t R)RRllt ]RRl4t ]RRl4t ]R(RRll4t R(RRllt RR lt R!R"lt R#R$lt R%R&ltR'tR#)*ra Assemble messages from frames. :class:`Assembler` expects only data frames. The stream of frames must respect the protocol; if it doesn't, the behavior is undefined. Args: pause: Called when the buffer of frames goes above the high water mark; should pause reading from the network. resume: Called when the buffer of frames goes below the low water mark; should resume reading from the network. Nc R#Nr_/home/wkmabra/.openclaw/workspace/venv/lib/python3.14/site-packages/websockets/sync/messages.pyAssembler.&s4rc R#rrrrrrr'sDrc ,V^8dQhRRRRRRRRRR/#) highz int | NonelowpausezCallable[[], Any]resumereturnNoner)formats"r __annotate__Assembler.__annotate__"s<$$$$! $ " $  $rc f\P!4Vn\P!4VnVeVf V^,pVfVe V^,pVe(Ve$V^8d \ R4hW8d \ R4hWuVnVnW0n W@n RVn RVn RVn R#)Nz%low must be positive or equal to zeroz)high must be greater than or equal to lowF) threadingLockmutexqueue SimpleQueueframes ValueErrorrrrr pausedget_in_progressclosed)selfrrrr s&&&&&r__init__Assembler.__init__"s^^% 8=7H7H7J   !)C ?;;   &   & ZZZs)B4.AAB4AA B44 C c$V^8dQhRRRRRR/#rr5r6decode Literal[True]r!strr)r#s"rr$r%usKK<KK3Krc R#rrr1r5rLs&&&rr< Assembler.gettsHKrc$V^8dQhRRRRRR/#rr5r6rLLiteral[False]r!bytesr)r#s"rr$r%xsNN<NNENrc R#rrrPs&&&rr<rQwsKNrc$V^8dQhRRRRRR/#rKr)r#s"rr$r%{sUU<U=USUrc R#rrrPs&&$rr<rQzsRUrc$V^8dQhRRRRRR/#rSr)r#s"rr$r%~sXX<X>XeXrc R#rrrPs&&$rr<rQ}UXrc$V^8dQhRRRRRR/#rr5r6rL bool | Noner!rr)r#s"rr$r%sXX<X XtXrc R#rrrPs&&&rr<rQr[rc$V^8dQhRRRRRR/#r]r)r#s"rr$r%s&FF<F FtFrc VP;_uu_4VP'd \R4hRVnRRR4\V4pVP VP RR74pVP;_uu_4VP 4RRR4VP\JgVP\JgQhVfVP\JpV.pVP'gyVP VP RR74pTP;_uu_4TP 4RRR4TP\JgQhTPT4KRVnRPRV44pV'dVP!4#V# +'giELr;i +'giEL,;i \dTPT4hi;i +'giL;i RTni;i)a Read the next message. :meth:`get` returns a single :class:`str` or :class:`bytes`. If the message is fragmented, :meth:`get` waits until the last frame is received, then it reassembles the message and returns it. To receive messages frame by frame, use :meth:`get_iter` instead. Args: timeout: If a timeout is provided and elapses before a complete message is received, :meth:`get` raises :exc:`TimeoutError`. decode: :obj:`False` disables UTF-8 decoding of text frames and returns :class:`bytes`. :obj:`True` forces UTF-8 decoding of binary frames and returns :class:`str`. Raises: EOFError: If the stream of frames has ended. UnicodeDecodeError: If a text frame contains invalid UTF-8. ConcurrencyError: If two coroutines run :meth:`get` or :meth:`get_iter` concurrently. TimeoutError: If a timeout is provided and elapses before a complete message is received. &get() or get_iter() is already runningTNF)raise_if_elapsedrc38"TFqPxK R#5ir)data).0r@s& r Assembler.get..s7u s)r)r/r rrAr5 maybe_resumeopcoder r finr?rHr rEjoinrL)r1r5rLdeadliner@r,res&&& rr<rQs4ZZZ###&'OPP#'D  )(H''(8(8%(8(PQE!!#<<7*elli.G GG~0WFiii // ((%(@EZZZ%%' ||w... e$ $)D xx777 ;;= KYZZ$$$V,   Z $)D sa%F#AG?F7AG?2!G G?'G,81G?# F4 7 G  G? G))G?, G< 7G?? Hc V^8dQhRRRR/#)rrLrMr!z Iterator[str]r)r#s"rr$r%sCC}CCrc R#rrr1rLs&&rget_iterAssembler.get_iters@Crc V^8dQhRRRR/#)rrLrTr!zIterator[bytes]r)r#s"rr$r%sFF~F/Frc R#rrrps&&rrqrrsCFrc V^8dQhRRRR/#rrLr^r!zIterator[Data]r)r#s"rr$r%sII{InIrc R#rrrps&&rrqrrsFIrc V^8dQhRRRR/#rvr)r#s"rr$r%s>%>%{>%n>%rc# "VP;_uu_4VP'd \R4hRVnRRR4VP4pVP;_uu_4VP 4RRR4VP \ JgVP \JgQhVfVP \ JpV'd4\4pVPVPVP4xM\VP4xVP'gVP4pVP;_uu_4VP 4RRR4VP \JgQhV'd+XPVPVP4xK\VP4xKRVnR# +'giEL;i +'giELp;i +'giL;i5i)a! Stream the next message. Iterating the return value of :meth:`get_iter` yields a :class:`str` or :class:`bytes` for each frame in the message. The iterator must be fully consumed before calling :meth:`get_iter` or :meth:`get` again. Else, :exc:`ConcurrencyError` is raised. This method only makes sense for fragmented messages. If messages aren't fragmented, use :meth:`get` instead. Args: decode: :obj:`False` disables UTF-8 decoding of text frames and returns :class:`bytes`. :obj:`True` forces UTF-8 decoding of binary frames and returns :class:`str`. Raises: EOFError: If the stream of frames has ended. UnicodeDecodeError: If a text frame contains invalid UTF-8. ConcurrencyError: If two coroutines run :meth:`get` or :meth:`get_iter` concurrently. rbTNF)r)r/r rArirjr r UTF8DecoderrLrerkrUr )r1rLr@decoders&& rrqrrsY2ZZZ###&'OPP#'D ##% ZZZ    ||w&%,,)*CCC >\\W,F !mG..UYY7 7 # #)))'')E!!#<<7* **nnUZZ;;EJJ''$KZZZZs`H%G ,H(G 9AH AH%$H G4%HA H G  H G1 + H4 H ?Hc V^8dQhRRRR/#)rr@rr!r"r)r#s"rr$r%s   4 rc VP;_uu_4VP'd \R4hVPP V4VP 4RRR4R# +'giR#;i)z_ Add ``frame`` to the next message. Raises: EOFError: If the stream of frames has ended. r:N)r)r0r>r,rF maybe_pause)r1r@s&&rrF Assembler.putsJZZZ{{{788 KKOOE "     ZZZs A A(( A9 cV^8dQhRR/#rr!r"r)r#s"rr$r%-s  T rc VPfR#VPP4'gQhVPP 4VP8d.VP 'gRVnVP 4R#R#R#)z7Pause the writer if queue is above the high water mark.NT)rr)lockedr,qsizer.rr1s&rr~Assembler.maybe_pause-se 99  zz  """" ;;    *4;;;DK JJL4? *rcV^8dQhRR/#rr)r#s"rr$r%:s  d rc VPfR#VPP4'gQhVPP 4VP8:d.VP 'dRVnVP 4R#R#R#)z7Resume the writer if queue is below the low water mark.NF)rr)rr,rr.r rs&rriAssembler.maybe_resume:se 88  zz  """" ;;   $(( *t{{{DK KKM0; *rcV^8dQhRR/#rr)r#s"rr$r%Gstrc \VP;_uu_4VP'd RRR4R#RVnVP'dVPP R4VP 'dRVnVP 4RRR4R# +'giR#;i)z End the stream of frames. Calling :meth:`close` concurrently with :meth:`get`, :meth:`get_iter`, or :meth:`put` is safe. They will raise :exc:`EOFError`. NTF)r)r0r/r,rFr.r rs&rcloseAssembler.closeGsjZZZ{{{ZDK### %{{{#  ZZZsBB ,B9B B+ ) r0r,r/rrr)rr.r r)NN)__name__ __module__ __qualname____firstlineno____doc__r2rArHr r<rqrFr~rir__static_attributes__rrrrrs   #/$0 $L,',KK NN UU XX XXFPCC FF II>%@ 2  r) __future__rcodecsr*r'typingrrrrrr exceptionsr r,r r r rrutilsr__all__getincrementaldecoderrzrrrrrsK" GG)77 -**73 IIr