ޠj:2SSKJr 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. NcgNrR/var/www/html/gaurav/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'' 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 ;;= KYZ$$$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 O[UR5v UR(dUR5nUR UR 5 SSS5 UR [LdeU(a)WRURUR5v O[UR5v UR(dMSUlg!,(df  GN=f!,(df  GNl=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 UTF8DecoderrFrQrWbytesr )r.rFr;decoders rr\r]sW2ZZ##&'OPP#'D ##% ZZ    ||w&%,,)*CCC >\\W,F !mG..UYY7 7 # #))'')E!!#<<7* **nnUZZ;;EJJ''))) %KZZsS G0$F;$G0G (CG0+G%@ 2  r) __future__rcodecsr#r typingrrrrrr exceptionsr r%r r rrrutilsr__all__getincrementaldecoderrarrrrrsK" GG)77 -**73 IIr