iy+SSKJr SSKrSSKrSSKrSSKJrJr SSKJ r J r J r J r J r Jr SSKJr SSKJrJrJrJr SSKJr S /r\R0"S 5r\ "S 5r"S S \ \5r"SS 5rg)) annotationsN) AsyncIteratorIterable)AnyCallableGenericLiteralTypeVaroverload)ConcurrencyError) OP_BINARYOP_CONTOP_TEXTFrame)Data Assemblerzutf-8TcX\rSrSrSrS SjrS SjrS SjrSSSjjrSSjr S Sjr S r g ) SimpleQueuezy Simplified version of :class:`asyncio.Queue`. Provides only the subset of functionality needed by :class:`Assembler`. cz[R"5UlSUl[R "5UlgN)asyncioget_running_looploop get_waiter collectionsdequequeueselfs X/home/mande/repo/quber/.venv/lib/python3.13/site-packages/websockets/asyncio/messages.py__init__SimpleQueue.__init__s),,. 7;+6+<+<+> c,[UR5$r)lenr r!s r#__len__SimpleQueue.__len__"s4::r&cURRU5 URb<URR5(dURR S5 ggg)zPut an item into the queue.N)r appendrdone set_result)r"items r#putSimpleQueue.put%sK $ ?? &t/C/C/E/E OO & &t ,0F &r&c# UR(d{U(d [S5eURbS5eURR 5UlURIShvN URR 5 SUlURR 5$N?!URR 5 SUlf=f7f)z?Remove and return an item from the queue, waiting if necessary.stream of frames endedNzcannot call get() concurrently)r EOFErrorrr create_futurecancelpopleft)r"blocks r#getSimpleQueue.get+szz788??* L,L L*"ii557DO 'oo%%&&("&zz!!## &&&("&s0ACB+)B)*B+.;C)B++#CCcURbS5eUR(aS5eURRU5 g)z)Put back items into an empty, idle queue.Nz%cannot reset() while get() is runningz&cannot reset() while queue isn't empty)rr extend)r"itemss r#resetSimpleQueue.reset9s<&O(OO&::GGG~ % r&cURbEURR5(d%URR[S55 ggg)z8Close the queue, raising EOFError in get() if necessary.Nr3)rr- set_exceptionr4r!s r#abortSimpleQueue.abort?s? ?? &t/C/C/E/E OO ) )(3K*L M0F &r&)rrr NreturnNone)rEint)r/rrErF)T)r8boolrEr)r=z Iterable[T]rErF) __name__ __module__ __qualname____firstlineno____doc__r$r)r0r9r>rB__static_attributes__r&r#rrs&? - $! Nr&rc\rSrSrSrSSSS4SSjjr\SSj5r\SSj5r\SSS jj5rSSS jjr\SS j5r\SS j5r\SSS jj5rSSSjjrSSjr SSjr SSjr SSjr Sr g)rEa 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. NcgrrOrOr&r#Assembler.Xs4r&cgrrOrOr&r#rSrTYsDr&c[5UlUbUcUS-nUcUbUS-nUb$Ub!US:a [S5eX:a [S5eXsUlUlX0lX@lSUlSUlSUl g)Nrz%low must be positive or equal to zeroz)high must be greater than or equal to lowF) rframes ValueErrorhighlowpauseresumepausedget_in_progressclosed)r"rZr[r\r]s r#r$Assembler.__init__Ts+6-   !)C  Assembler.get..s7u s)r_r rXr9r` maybe_resumeopcoderrfinrCancelledErrorr>rr,joinrd)r"rdrnrXrls r#r9res\,   "#KL L#  )++//dkk/::E    <<7*elli.G GG~0WFii"&++//dkk/"BBE !!#||w... e$iii$)D xx777 ;;= K9;C--KK%%f- $)D sZ$F3-F'E.A%F';-E3(E1)E3-AF'68F3.F'1E331F$$F'' F00F3cgrrOrcs r#get_iterAssembler.get_itersEHr&cgrrOrcs r#rwrxsHKr&cgrrOrcs r#rwrxsKNr&c# UR(a [S5eSUlURRUR(+5IShvN nUR5 UR[LdUR[LdeUcUR[LnU(a4[5nURURUR57v O[UR57v UR(dURRUR(+5IShvN nUR5 UR[ LdeU(a*WRURUR57v O[UR57v UR(dMSUlgGNq![ R a SUlef=fN7f)a0 Stream the next message. Iterating the return value of :meth:`get_iter` asynchronously 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. rjTNF)r_r rXr9r`rrtrqrrrr UTF8Decoderrdrlrsbytesr)r"rdrndecoders r#rwrxsf2   "#KL L# ++//dkk/::E ||w&%,,)*CCC >\\W,F !mG..UYY7 7 # #)) ++//dkk/::E    <<7* **nnUZZ;;EJJ''))) %=;%% #(D  (;sB$G*-GGGCG*7G(8BG*=G*GG%%G*cUR(a [S5eURRU5 UR 5 g)z_ Add ``frame`` to the next message. Raises: EOFError: If the stream of frames has ended. r3N)r`r4rXr0 maybe_pause)r"rns r#r0 Assembler.put s3 ;;34 4  r&cURcg[UR5UR:a*UR(dSUlUR 5 ggg)z7Pause the writer if queue is above the high water mark.NT)rZr(rXr^r\r!s r#rAssembler.maybe_pausesF 99   t{{ dii ' DK JJL1< 'r&cURcg[UR5UR::a*UR(aSUlUR 5 ggg)z7Resume the writer if queue is below the low water mark.NF)r[r(rXr^r]r!s r#rqAssembler.maybe_resume#sF 88   t{{ txx 'DKKDK KKM-8 'r&cjUR(agSUlURR5 g)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)r`rXrBr!s r#closeAssembler.close.s' ;;   r&)r`rXr_rZr[r\r^r]) rZ int | Noner[rr\Callable[[], Any]r]rrErF)rd Literal[True]rEstr)rdLiteral[False]rEr}r)rd bool | NonerEr)rdrrEzAsyncIterator[str])rdrrEzAsyncIterator[bytes])rdrrEzAsyncIterator[Data])rnrrErFrD)rIrJrKrLrMr$r r9rwr0rrqrrNrOr&r#rrEs   #/$0   !  "   D:: == @@;zHH KK NNC%J   r&) __future__rrcodecsrcollections.abcrrtypingrrrr r r exceptionsr rXrrrrr__all__getincrementaldecoderr|rrrrOr&r#rsg" 3EE)77 -**73  CL-N'!*-N`wwr&