vKg(SSKJr SSKrSSKrSSKrSSKJrJr SSKJ r J r J r J r SSK Jr SSKJrJrJrJr SSKJr S /r\R,"S 5r\ "S 5r"S S \ \5r"SS 5rg)) annotationsN) AsyncIteratorIterable)AnyCallableGenericTypeVar)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 [/var/www/highfloat_scraper/venv/lib/python3.13/site-packages/websockets/asyncio/messages.py__init__SimpleQueue.__init__s),,. 7;+6+<+<+> c,[UR5$r)lenrrs r!__len__SimpleQueue.__len__"s4::r$cURRU5 URb<URR5(dURR S5 ggg)z+Put an item into the queue without waiting.N)rappendrdone 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)rEOFErrorrr 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)rrextend)r itemss r!resetSimpleQueue.reset9s<&O(OO&::GGG~ % r$cURbEURR5(d%URR[S55 ggg)z8Close the queue, raising EOFError in get() if necessary.Nr1)rr+ set_exceptionr2rs r!abortSimpleQueue.abort?s? ?? &t/C/C/E/E OO ) )(3K*L M0F &r$)rrrNreturnNone)rCint)r-rrCrD)T)r6boolrCr)r;z Iterable[T]rCrD) __name__ __module__ __qualname____firstlineno____doc__r"r'r.r7r<r@__static_attributes__r$r!rrs&? - $! Nr$rc\rSrSrSrSSSS4SSjjrSSSjjrSSSjjrSS jrSS jr SS jr SS jr S r 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. NcgrrMrMr$r!Assembler.Ys4r$cgrrMrMr$r!rQrRZsDr$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 rXrYrZr[s r!r"Assembler.__init__Us+6-   !)C  Assembler.get..s7u s)r]r rVr7r^ maybe_resumeopcoderr finrCancelledErrorr<r r*joindecode)r rmrerVrcs r!r7 Assembler.getwsZ,   "#KL L#  )++//dkk/::E    <<7*elli.G GG~0WFii"&++//dkk/"BBE !!#||w... e$iii$)D xx777 ;;= K7;C--KK%%f- $)D sZ$F3-F'E.A%F';-E3(E1)E3-AF'68F3.F'1E331F$$F'' F00F3c# UR(a [S5eSUlURRUR(+5IShvN nUR5 UR[LdUR[LdeUcUR[LnU(a4[5nURURUR57v OUR7v UR(dURRUR(+5IShvN nUR5 UR[LdeU(a*WRURUR57v OUR7v UR(dMSUlgGN_![ 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. raTNF)r]r rVr7r^rrkrhrirr UTF8Decoderrmrcrjr )r rmredecoders r!get_iterAssembler.get_itersX2   "#KL L# ++//dkk/::E ||w&%,,)*CCC >\\W,F !mG..UYY7 7** )) ++//dkk/::E    <<7* **nnUZZ;;jj ))) %9;%% #(D  &;sB$G-F6F3F6CG.G/A:G+G3F66GGcUR(a [S5eURRU5 UR 5 g)z_ Add ``frame`` to the next message. Raises: EOFError: If the stream of frames has ended. r1N)r^r2rVr. maybe_pause)r res r!r. Assembler.puts3 ;;34 4  r$cURcg[UR5UR:a*UR(dSUlUR 5 ggg)z7Pause the writer if queue is above the high water mark.NT)rXr&rVr\rZrs r!ruAssembler.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)rYr&rVr\r[rs r!rhAssembler.maybe_resumesF 88   t{{ txx 'DKKDK KKM-8 'r$cjUR(agSUlURR5 g)z End the stream of frames. Callling :meth:`close` concurrently with :meth:`get`, :meth:`get_iter`, or :meth:`put` is safe. They will raise :exc:`EOFError`. NT)r^rVr@rs r!closeAssembler.closes' ;;   r$)r^rVr]rXrYrZr\r[) rX int | NonerYr~rZCallable[[], Any]r[rrCrDr)rm bool | NonerCr)rmrrCzAsyncIterator[Data])rerrCrDrB) rGrHrIrJrKr"r7rrr.rurhr|rLrMr$r!rrEsl " #/$0   !  "   D:xA%F   r$) __future__rrcodecsrcollections.abcrrtypingrrrr exceptionsr rVr r rrr__all__getincrementaldecoderrprrrrMr$r!rsg" 322)77 -**73  CL-N'!*-N`ccr$