Fg-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. NcgNri/Users/admin/workspace/ai/PDFMathTranslate/myenv/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 SS95nUR UR 5 SSS5 UR[LdUR[LdeUcUR[LnU/nUR(d}UR UR SS95nUR UR 5 SSS5 UR[LdeURU5 UR(dM}SUlSRSU55nU(aUR!5$U$!,(df  GNd=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 runningTNF)raise_if_elapsedrc38# UHoRv M g7fr)data).0r9s r Assembler.get..s7u s)r r*r rr:r3 maybe_resumeopcoder r finr8r@r r=joindecode)r,r3rNdeadliner9r#rFs rr5 Assembler.getqs4ZZ##&'OPP#'D  )(H''(8(8%(8(PQE!!#<<7*elli.G GG~0WFii // ((%(@EZZ%%' ||w... e$iii $)D xx777 ;;= KWZ$$$V,   Z $)D s_$F5G#/F AG#F28 G#G?G# F F/*G#2GG# 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:rJrKr r UTF8DecoderrNrFrLr )r,rNr9decoders 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 rrWAssembler.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 rZr#r[r)r(r\s rrJAssembler.maybe_resumesc 88  zz  """" ;;   $(( *t{{DK KKM0; *rc<UR UR(a SSS5 gSUlUR(aURR S5 UR (aSUlUR 5 SSS5 g!,(df  g=f)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 r+r*r#r>r)r(r\s rcloseAssembler.close)s_ZZ{{ZDK## %{{#  ZZsB AB  B) r+r#r*r%r&r r'r)r() r% int | Noner&rcr'Callable[[], Any]r(rdreturnNoner)r3 float | Nonerer )r#zIterable[Frame]rerf)NN)r3rgrN bool | Nonerer)rNrhrezIterator[Data])r9r rerf)rerf)__name__ __module__ __qualname____firstlineno____doc__r-r:r@r5rTr>rWrJra__static_attributes__rrrrrsv   #/$0 $$$! $ " $  $L,'&EN<%| 2  r) __future__rcodecsr!rtypingrrrr exceptionsr r#r r r r rutilsr__all__getincrementaldecoderrRrrrrrvsK" 44)77 -**73 kkr