vKg+SSKJr SSKrSSKrSSKrSSKJrJrJrJ r SSK J r SSK J r JrJrJr SSKJr SS KJr S /r\R*"S 5r"S S 5rg) ) annotationsN)AnyCallableIterableIterator)ConcurrencyError) OP_BINARYOP_CONTOP_TEXTFrame)Data)Deadline Assemblerzutf-8c\rSrSrSrSSSS4SSjjrSSSjjrSSjrSSS jjrSSS jjr SS jr SS jr SS jr SSjr Srg)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. NcgNrX/var/www/highfloat_scraper/venv/lib/python3.13/site-packages/websockets/sync/messages.pyAssembler.&s4rcgrrrrrrr'sDrcD[R"5Ul[R"5UlUbUcUS-nUcUbUS-nUb$Ub!US:a [ S5eX:a [ S5eXsUlUlX0l X@l SUl SUl SUl g)Nrz%low must be positive or equal to zeroz)high must be greater than or equal to lowF) threadingLockmutexqueue SimpleQueueframes ValueErrorhighlowpauseresumepausedget_in_progressclosed)selfr%r&r'r(s r__init__Assembler.__init__"s^^% 8=7H7H7J   !)C ?;;   &   & ZZs'B'+<AB'AA B'' B5cUR UR(a [S5eSUlSSS5 [U5nUR UR 55nUR UR 5 SSS5 UR[LdUR[LdeUcUR[LnU/nUR(d~UR UR 55nUR UR 5 SSS5 UR[LdeURU5 UR(dM~SUlSRSU55nU(aUR!5$U$!,(df  GNf=f!,(df  GN(=f![a URU5 ef=f!,(df  N=f!SUlf=f)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 runningTNFrc36# UHoRv M g7fr)data).0r9s r Assembler.get..s7u s)r r*r rr:r3 maybe_resumeopcoder r finr8r@r r=joindecode)r,r3rMdeadliner9r#rEs rr5 Assembler.getls4ZZ##&'OPP#'D  )(H''(8(8(:;E!!#<<7*elli.G GG~0WFii //0@0@0BCE ZZ%%' ||w... e$iii$)D xx777 ;;= KSZ$$$V,   Z $)D s_$F6G%0F"AG%F4: G%G?G% F" F1,G%4GG% G"G%% G.c## UR UR(a [S5eSUlSSS5 UR5nUR UR 5 SSS5 UR [ LdUR [LdeUcUR [ LnU(a3[5nURURUR5v OURv UR(dUR5nUR UR 5 SSS5 UR [LdeU(a)WRURUR5v OURv UR(dMSUlg!,(df  GN}=f!,(df  GNZ=f!,(df  N=f7f)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. rCTNF) r r*r r:rIrJr r UTF8DecoderrMrErKr )r,rMr9decoders rget_iterAssembler.get_itersI2ZZ##&'OPP#'D ##% ZZ    ||w&%,,)*CCC >\\W,F !mG..UYY7 7** ))'')E!!#<<7* **nnUZZ;;jj ))) %GZZsS G$F)$GF;(B:G"G 3A,G!G) F83G; G G GGcUR UR(a [S5eURR U5 UR 5 SSS5 g!,(df  g=f)z_ Add ``frame`` to the next message. Raises: EOFError: If the stream of frames has ended. r2N)r r+r7r#r> maybe_pause)r,r9s rr> Assembler.putsDZZ{{788 KKOOE "     ZZs AA A,cURcgURR5(deURR 5UR:a*UR (dSUlUR 5 ggg)z7Pause the writer if queue is above the high water mark.NT)r%r lockedr#qsizer)r'r,s rrVAssembler.maybe_pausesc 99  zz  """" ;;    *4;;DK JJL4? *rcURcgURR5(deURR 5UR::a*UR (aSUlUR 5 ggg)z7Resume the writer if queue is below the low water mark.NF)r&r rYr#rZr)r(r[s rrIAssembler.maybe_resumesc 88  zz  """" ;;   $(( *t{{DK KKM0; *rcUR UR(a SSS5 gSUlUR(aURR S5 SSS5 g!,(df  g=f)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 r+r*r#r>r[s rcloseAssembler.close"sHZZ{{ZDK## %ZZsA%3A%% A3) r+r#r*r%r&r r'r)r() r% int | Noner&rbr'Callable[[], Any]r(rcreturnNoner)r3 float | Nonerdr )r#zIterable[Frame]rdre)NN)r3rfrM bool | Nonerdr)rMrgrdzIterator[Data])r9r rdre)rdre)__name__ __module__ __qualname____firstlineno____doc__r-r:r@r5rSr>rVrIr`__static_attributes__rrrrrsv   #/$0 $$$! $ " $  $L"'&CJ<%| 2  &r) __future__rcodecsr!rtypingrrrr exceptionsr r#r r r r rutilsr__all__getincrementaldecoderrQrrrrrusK" 44)77 -**73 _&_&r