+ iy+^RIHt^RIt^RIt^RIt^RIHtHt^RIH t H t H t H t H t Ht^RIHt^RIHtHtHtHt^RIHtR.t]P0!R 4t] !R 4t!R R ] ],4t!R R4tR#)) annotationsN) AsyncIteratorIterable)AnyCallableGenericLiteralTypeVaroverload)ConcurrencyError) OP_BINARYOP_CONTOP_TEXTFrame)Data Assemblerzutf-8Tcf]tRt^tRtRRltRRltRRltRRR lltR R lt R R lt Rt R#) SimpleQueuezy Simplified version of :class:`asyncio.Queue`. Provides only the subset of functionality needed by :class:`Assembler`. cV^8dQhRR/#returnNone)formats"b/home/wkmabra/.openclaw/workspace/venv/lib/python3.14/site-packages/websockets/asyncio/messages.py __annotate__SimpleQueue.__annotate__s??$?c |\P!4VnRVn\P !4VnR#N)asyncioget_running_looploop get_waiter collectionsdequequeueselfs&r__init__SimpleQueue.__init__s),,. 7;+6+<+<+> r cV^8dQhRR/#)rrintr)rs"rrr"sr c ,\VP4#r")lenr)r*s&r__len__SimpleQueue.__len__"s4::r c V^8dQhRRRR/#)ritemrrrr)rs"rrr%s---d-r c VPPV4VPe@VPP4'gVPP R4R#R#R#)zPut an item into the queue.N)r)appendr&done set_result)r+r5s&&rputSimpleQueue.put%sK $ ?? &t/C/C/E/E OO & &t ,0F &r c V^8dQhRRRR/#)rblockboolrrr)rs"rrr+s $ $t $q $r c "VP'g~V'g \R4hVPeQR4hVPP 4VnVPGRjxL VPP 4RVnVPP 4#L? TPP 4RTni;i5i)z?Remove and return an item from the queue, waiting if necessary.stream of frames endedNzcannot call get() concurrently)r)EOFErrorr&r% create_futurecancelpopleft)r+r=s&&rgetSimpleQueue.get+szzz788??* L,L L*"ii557DO 'oo%%&&("&zz!!## &&&("&s4C?CB.,B,-B.1;C,B..#CCc V^8dQhRRRR/#)ritemsz Iterable[T]rrr)rs"rrr9s!!;!4!r c VPeQR4hVP'dQR4hVPPV4R#)z)Put back items into an empty, idle queue.Nz%cannot reset() while get() is runningz&cannot reset() while queue isn't empty)r&r)extend)r+rHs&&rresetSimpleQueue.reset9s>&O(OO&:::GGG~ % r cV^8dQhRR/#rr)rs"rrr?sNNtNr c VPeIVPP4'g'VPP\R44R#R#R#)z8Close the queue, raising EOFError in get() if necessary.Nr@)r&r8 set_exceptionrAr*s&rabortSimpleQueue.abort?s? ?? &t/C/C/E/E OO ) )(3K*L M0F &r )r&r%r)N)T) __name__ __module__ __qualname____firstlineno____doc__r,r2r:rErKrP__static_attributes__rr rrrs,? - $! NNr rc]tRt^EtRtRRRR3RRllt]RRl4t]R R l4t]R R R ll4tR R Rllt]RRl4t]RRl4t]R RRll4tR RRlltRRlt RRlt RRlt RRlt Rt R#)!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#r"rrr rAssembler.Xs4r c R#r"rrr rrZr[YsDr c ,V^8dQhRRRRRRRRRR/#) rhighz int | NonelowpausezCallable[[], Any]resumerrr)rs"rrAssembler.__annotate__Ts<    !  "   r c \4VnVeVf V^,pVfVe V^,pVe(Ve$V^8d \R4hW8d \R4hWuVnVnW0nW@nRVnRVnRVn R#)Nz%low must be positive or equal to zeroz)high must be greater than or equal to lowF) rframes ValueErrorr^r_r`rapausedget_in_progressclosed)r+r^r_r`ras&&&&&rr,Assembler.__init__Ts+6-   !)C  Assembler.get..s7u s)rgr rdrErh maybe_resumeopcoderr finr#CancelledErrorrKrr7joinrk)r+rkrrdr~s&& rrErps[,    "#KL L#  )++//dkk/::E    <<7*elli.G GG~0WFiii"&++//dkk/"BBE !!#||w... e$ $)D xx777 ;;= K9;C--KK%%f- $)D s_%F+-FE%A(F-E*-E(.E*29F,&F+F+%F(E**2FF F((F+c V^8dQhRRRR/#)rrkrlrzAsyncIterator[str]r)rs"rrrbsHH}H1CHr c R#r"rros&&rget_iterAssembler.get_itersEHr c V^8dQhRRRR/#)rrkrsrzAsyncIterator[bytes]r)rs"rrrbsKK~K2FKr c R#r"rros&&rrrsHKr c V^8dQhRRRR/#rrkrxrzAsyncIterator[Data]r)rs"rrrbsNN{N6INr c R#r"rros&&rrrsKNr c V^8dQhRRRR/#rr)rs"rrrbsC%C%[C%\\W,F !mG..UYY7 7 # #))) ++//dkk/::E    <<7* **nnUZZ;;EJJ''$=;%% #(D  (;sO%G$-GF>GAG$2AG$-G$=G">1G$0AG$>GGG$c V^8dQhRRRR/#)rrrrrr)rs"rrrb s   4 r c VP'd \R4hVPPV4VP 4R#)z_ Add ``frame`` to the next message. Raises: EOFError: If the stream of frames has ended. r@N)rhrArdr: maybe_pause)r+rs&&rr: Assembler.put s5 ;;;34 4  r cV^8dQhRR/#rr)rs"rrrbs  T r c VPfR#\VP4VP8d.VP'gRVnVP 4R#R#R#)z7Pause the writer if queue is above the high water mark.NT)r^r1rdrfr`r*s&rrAssembler.maybe_pausesH 99   t{{ dii ' DK JJL1< 'r cV^8dQhRR/#rr)rs"rrrb#s  d r c VPfR#\VP4VP8:d.VP'dRVnVP 4R#R#R#)z7Resume the writer if queue is below the low water mark.NF)r_r1rdrfrar*s&rrAssembler.maybe_resume#sH 88   t{{ txx 'DKKKDK KKM-8 'r cV^8dQhRR/#rr)rs"rrrb.str c pVP'dR#RVnVPP4R#)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`. NT)rhrdrPr*s&rcloseAssembler.close.s) ;;;   r )rhrdrgr^r_r`rfrar")rRrSrTrUrVr,r rErr:rrrrWrr rrrEs   #/$0 D:: == @@;zHH KK NNC%J   r ) __future__rr#codecsr'collections.abcrrtypingrrrr r r exceptionsr rdr rrrr__all__getincrementaldecoderrrrrrr rrsg" 3EE)77 -**73  CL-N'!*-N`wwr