+h:$ddlmZddlmZmZddlmZmZddlm Z ddl m Z m Z m Z ddlmZmZmZmZmZddlmZdd lmZmZmZdd lmZe d Ze d d Ze dd ZGdde ZedGdde eZ edGdde eeeZ!edGdde eeeZ"y)) annotations) OrderedDictdeque) dataclassfield) TracebackType)Generic NamedTupleTypeVar)BrokenResourceErrorClosedResourceError EndOfStream WouldBlockget_cancelled_exc_class)DeprecatedAwaitable)EventObjectReceiveStreamObjectSendStream) checkpointT_ItemT_coT) covariantT_contra) contravariantcJeZdZUded<ded<ded<ded<ded<ded<y ) MemoryObjectStreamStatisticsintcurrent_buffer_usedfloatmax_buffer_sizeopen_send_streamsopen_receive_streamstasks_waiting_sendtasks_waiting_receiveN)__name__ __module__ __qualname____annotations__G/var/www/html/venv/lib/python3.12/site-packages/anyio/streams/memory.pyrrs&r+rF)eqceZdZUeZded<edeZded<eddZd ed <eddZ d ed <ede Z d ed <ede Z ded<ddZ y)MemoryObjectStreamStater r!F)initdefault_factoryz deque[T_Item]bufferrr0defaultropen_send_channelsopen_receive_channelsz OrderedDict[Event, list[T_Item]]waiting_receiverszOrderedDict[Event, T_Item]waiting_sendersc tt|j|j|j|j t|j t|jSN)rlenr2r!r5r6r8r7selfs r, statisticsz"MemoryObjectStreamState.statistics0sR+     # #  & & $$ % && '   r+Nreturnr)r&r'r(rr!r)rr2r5r6rr7r8r>r*r+r,r/r/#sy"WOU$!ueDFMD#::!&E1!=3=:? K;738 K3O/ r+r/ceZdZUded<eddZded<ddZddZdd Zdd Z dd Z dd Z dd Z ddZ ddZy)MemoryObjectReceiveStreamzMemoryObjectStreamState[T_co]_stateFr3bool_closedcB|jxjdz c_yN)rCr6r<s r, __post_init__z'MemoryObjectReceiveStream.__post_init__@s ))Q.)r+c|jrt|jjr^|jjj d\}}|jj j ||j|jj r$|jj jS|jjstt)a Receive the next item if it can be done without waiting. :return: the received item :raises ~anyio.ClosedResourceError: if this send stream has been closed :raises ~anyio.EndOfStream: if the buffer is empty and this stream has been closed from the sending end :raises ~anyio.WouldBlock: if there are no items in the buffer and no tasks waiting to send Flast) rErrCr8popitemr2appendsetpopleftr5rr)r= send_eventitems r,receive_nowaitz(MemoryObjectReceiveStream.receive_nowaitCs <<% % ;; & &#{{::BBBN J KK   % %d + NN  ;;  ;;%%--/ /// r+cKtd{ |jS7#t$rt}g}||jj |< |j d{7n#t$r|sYnwxYw|jj j|dn+#|jj j|dwxYw|r|dcYStwxYww)Nr) rrSrrrCr7waitrpopr)r= receive_event containers r,receivez!MemoryObjectReceiveStream.receive_sl "&&( (  "!GM$&I;DDKK ) )- 8 G#((****, !!   --11-F --11-F |#!!' "spC,&C,(C,.C)A1*A-+A10B.1BB.BB.'C).(C C) C,"C))C,cR|jrtt|jS)a Create a clone of this receive stream. Each clone can be closed separately. Only when all clones have been closed will the receiving end of the memory stream be considered closed by the sending ends. :return: the cloned stream rC)rErrBrCr<s r,clonezMemoryObjectReceiveStream.clonexs  <<% %( <#>#C#C#EF ( EIIK 6r+c,K|jywr:rcr<s r,aclosez MemoryObjectReceiveStream.aclose c6|jjSzj Return statistics about the current state of this stream. .. versionadded:: 3.0 rCr>r<s r,r>z$MemoryObjectReceiveStream.statistics {{%%''r+c|Sr:r*r<s r, __enter__z#MemoryObjectReceiveStream.__enter__ r+c$|jyr:rer=exc_typeexc_valexc_tbs r,__exit__z"MemoryObjectReceiveStream.__exit__ r+Nr@None)r@r)r@zMemoryObjectReceiveStream[T_co]r?rrztype[BaseException] | NonerszBaseException | NonertzTracebackType | Noner@rx)r&r'r(r)rrErIrSrYr\rcrfr>rnrur*r+r,rBrB;sl ))ue4GT4/8"2 = (,&%   r+rBceZdZUded<eddZded<ddZddZdd Zdd Z dd Z dd Z dd Z ddZ ddZy)MemoryObjectSendStreamz!MemoryObjectStreamState[T_contra]rCFr3rDrEcB|jxjdz c_yrG)rCr5r<s r,rIz$MemoryObjectSendStream.__post_init__s &&!+&r+c|jrt|jjst|jj rK|jj j d\}}|j||jnbt|jj|jjkr&|jjj|ntt|jS)a Send an item immediately if it can be done without waiting. :param item: the item to send :raises ~anyio.ClosedResourceError: if this send stream has been closed :raises ~anyio.BrokenResourceError: if the stream has been closed from the receiving end :raises ~anyio.WouldBlock: if the buffer is full and there are no tasks waiting to receive FrK)rErrCr6r r7rMrNrOr;r2r!rr send_nowait)r=rRrWrXs r,r~z"MemoryObjectSendStream.send_nowaits <<% %{{00% % ;; ( ('+{{'D'D'L'LRW'L'X $M9   T "     ## $t{{'B'B B KK   % %d + "4#3#344r+cKtd{ |j|y7#t$rt}||jj |< |j d{7n4#t$r(|jj j|dwxYw|jj j|drtYywxYwwr:) rr~rrrCr8rU BaseExceptionrVr )r=rRrQs r,sendzMemoryObjectSendStream.sendsl *   T "  *J6:DKK ' ' 3  oo'''   ++// DA {{**..z4@))A *sRC(C*C,CA1*A-+A10C11B""/CCCCcR|jrtt|jS)a  Create a clone of this send stream. Each clone can be closed separately. Only when all clones have been closed will the sending end of the memory stream be considered closed by the receiving ends. :return: the cloned stream r[)rErr{rCr<s r,r\zMemoryObjectSendStream.clones  <<% %%T[[99r+cn|jsd|_|jxjdzc_|jjdk(rit|jjj }|jjj |D]}|jyyyr^)rErCr5r_r7r`clearrO)r=receive_eventsrbs r,rczMemoryObjectSendStream.closes||DL KK * *a / *{{--2!%dkk&C&C&H&H&J!K --335+ EIIK 3r+c,K|jywr:rer<s r,rfzMemoryObjectSendStream.aclosergrhc6|jjSrjrkr<s r,r>z!MemoryObjectSendStream.statisticsrlr+c|Sr:r*r<s r,rnz MemoryObjectSendStream.__enter__ror+c$|jyr:rerqs r,ruzMemoryObjectSendStream.__exit__rvr+Nrw)rRrr@r)rRrr@rx)r@z MemoryObjectSendStream[T_contra]r?ry)r&r'r(r)rrErIr~rr\rcrfr>rnrur*r+r,r{r{sl --ue4GT4,58*" : "(,&%   r+r{N)# __future__r collectionsrr dataclassesrrtypesrtypingr r r r rrrr _core._compatrabcrrrlowlevelrrrrrr/rBr{r*r+r,rs"*(//0>>!  v& :T 2: e gfo  . eo /B4/Hood ehWX.0@0Jhhr+