;Ig+ddlmZddlZddlZddlZddlmZmZmZm Z ddl m Z ddl m Z mZmZmZddlmZdd lmZd gZej*d ZGd d Zy) ) annotationsN)AnyCallableIterableIterator)ConcurrencyError) OP_BINARYOP_CONTOP_TEXTFrame)Data)Deadline Assemblerzutf-8c~eZdZdZddddf ddZdddZddZdddZddd Zdd Z dd Z dd Z dd Z y)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. NcyNrU/var/www/html/answerous/venv/lib/python3.12/site-packages/websockets/sync/messages.pyzAssembler.&rcyrrrrrrzAssembler.'rrc8tj|_tj|_|||dz}|||dz}|"| |dkr t d||kr t d||c|_|_||_ ||_ d|_ d|_ d|_ y)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__zAssembler.__init__"s^^% 8=7H7H7J   !)C ?;;   ' & '  ' & ' ' ' 's'B%->AB%AAB%%B.c|j5|jr tdd|_ddd t|}|j |j }|j5|j ddd|jtus|jtusJ||jtu}|g}|jsw |j |j }|j5|j ddd|jtusJ|j||jswd|_djd|D}|r|j!S|S#1swYMxYw#1swY xYw#t$r|j|wxYw#1swYxYw#d|_wxYw)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 runningTNFrc34K|]}|jywr)data).0r7s r z Assembler.get..s7u 7s)rr)r rr8r1 maybe_resumeopcoder r finr6r=r r:joindecode)r+r1rHdeadliner7r"rAs rr3z Assembler.getls4ZZ (##&'OPP#'D  ( )(H''(8(8(:;E $!!# $<<7*elli.G GG~0WFii //0@0@0BCE ZZ(%%'(||w... e$ii$)D xx777 ;;= KS ( ( $ $$$$V,  (( $)D s_E76F<+F\\W,F !mG..UYY7 7** ))'')E $!!# $<<7* **nnUZZ;;jj )) %G ( (   $ $sS F1F $F1F#B-F1F%!A!F1F1 FF1F"F1%F.*F1c|j5|jr td|jj ||j dddy#1swYyxYw)z Add ``frame`` to the next message. Raises: EOFError: If the stream of frames has ended. r0N)rr*r5r"r; maybe_pause)r+r7s rr;z Assembler.putsOZZ {{788 KKOOE "        s AAA"c|jy|jjsJ|jj |jkDr%|j sd|_|j yyy)z7Pause the writer if queue is above the high water mark.NT)r$rlockedr"qsizer(r&r+s rrOzAssembler.maybe_pauses` 99  zz  """ ;;    *4;;DK JJL4? *rc|jy|jjsJ|jj |jkr%|j rd|_|j yyy)z7Resume the writer if queue is below the low water mark.NF)r%rrQr"rRr(r'rSs rrDzAssembler.maybe_resumes` 88  zz  """ ;;   $(( *t{{DK KKM0; *rc|j5|jr dddyd|_|jr|jj ddddy#1swYyxYw)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)rr*r)r"r;rSs rclosezAssembler.close"sVZZ &{{ & &DK## % & & &sA.AA$) r$ int | Noner%rWr&Callable[[], Any]r'rXreturnNoner)r1 float | NonerYr )r"zIterable[Frame]rYrZ)NN)r1r[rH bool | NonerYr)rHr\rYzIterator[Data])r7r rYrZ)rYrZ) __name__ __module__ __qualname____doc__r,r8r=r3rMr;rOrDrVrrrrrsv   #/$0 $$$! $ " $  $L"'&CJ<%| 2  &r) __future__rcodecsr rtypingrrrr exceptionsr r"r r r r rutilsr__all__getincrementaldecoderrKrrrrrhsM" 44)77 -*f**73 _&_&r