5h?1SSKJr SSKrSSKrSSKrSSKJrJrJrJ r J r J r SSK J r SSKJrJrJrJr SSKJr SS KJr S /r\R."S 5r"S S 5rg) ) annotationsN)AnyCallableIterableIteratorLiteraloverload)ConcurrencyError) OP_BINARYOP_CONTOP_TEXTFrame)Data)Deadline Assemblerzutf-8cP\rSrSrSrSSSS4SSjjrSSSjjrSSjr\SS j5r \SS j5r \SSS jj5r \SSS jj5r \SSS jj5r SSSjjr \S Sj5r \S!Sj5r \SS"Sjj5r SS"Sjjr S#Sjr S$Sjr S$Sjr S$SjrSrg)%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. NcgNrc/var/www/html/cementerio_25MayoBackend/env/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'' B5cgrrr.r5decodes rr7 Assembler.gettsHKrcgrrrEs rr7rGwsKNrcgrrrEs rr7rGzsRUrcgrrrEs rr7rG}UXrcgrrrEs rr7rGrKrcUR 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_elapsedrc36# UHoRv M g7fr)data).0r;s r Assembler.get..s7u s)r"r,r rr<r5 maybe_resumeopcoderr finr:rBr r?joinrF)r.r5rFdeadliner;r%rQs rr7rGs4ZZ##&'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,cgrrr.rFs rget_iterAssembler.get_iters@Crcgrrr[s rr\r]sCFrcgrrr[s rr\r]sFIrc## 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. rNTNF) r"r,r r<rUrVrr UTF8DecoderrFrQrWr )r.rFr;decoders rr\r]sI2ZZ##&'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. r4N)r"r-r9r%r@ maybe_pause)r.r;s 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 rrdAssembler.maybe_pause*sc 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"rgr%rhr+r*ris rrUAssembler.maybe_resume7sc 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*ris rcloseAssembler.closeDs_ZZ{{ZDK## %{{#  ZZsB AB  B) r-r%r,r'r(r"r)r+r*) r' int | Noner(rpr)Callable[[], Any]r*rqreturnNoner)r5 float | Nonerrr)r%zIterable[Frame]rrrs)r5rtrF Literal[True]rrstr)r5rtrFLiteral[False]rrbytes)NN)r5rtrF bool | Nonerrr)rFrurrz Iterator[str])rFrwrrzIterator[bytes])rFryrrzIterator[Data])r;rrrrs)rrrs)__name__ __module__ __qualname____firstlineno____doc__r/r<rBr r7r\r@rdrUrn__static_attributes__rrrrrs   #/$0 $$$! $ " $  $L,',KK NN UU XX XXENCC FF II<%| 2  r) __future__rcodecsr#r typingrrrrrr exceptionsr r%r r rrrutilsr__all__getincrementaldecoderrarrrrrsK" GG)77 -**73 FFr