+
    ~j                    4   ^ RI Ht ^ RIt^ RIt^ RIHt ^ RIHt ^ RIH	t	H
t
Ht ]! R4      t]! RRR	7      t]! R
RR7      t ! R R]4      t ! R R]4      t ! R R]4      t ! R R]
],          4      t ! R R]
],          4      t ! R R]	],          4      tR# )    )annotationsN)deque)AsyncIterator)GenericProtocolTypeVarTT_coT)	covariantT_contra)contravariantc                      ] tR t^tRtR# )
ChanClosed N__name__
__module____qualname____firstlineno____static_attributes__r       u/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/livekit/agents/utils/aio/channel.pyr   r          r   r   c                      ] tR t^tRtR# )ChanFullr   Nr   r   r   r   r   r      r   r   r   c                      ] tR t^tRtR# )	ChanEmptyr   Nr   r   r   r   r   r      r   r   r   c                  :    ] tR t^tR R ltR R ltR R ltRtR# )	
ChanSenderc                    V ^8  d   QhRRRR/#    valuer   returnNoner   )formats   "r   __annotate__ChanSender.__annotate__   s    666T6r   c                	   "   R # 5iNr   selfr#   s   &&r   sendChanSender.send   s     3   c                    V ^8  d   QhRRRR/# r!   r   )r&   s   "r   r'   r(       s    777d7r   c                	    R # r*   r   r+   s   &&r   send_nowaitChanSender.send_nowait    s    Cr   c                   V ^8  d   QhRR/# r"   r$   r%   r   )r&   s   "r   r'   r(   "         t r   c                	    R # r*   r   r,   s   &r   closeChanSender.close"       Sr   r   N)r   r   r   r   r-   r2   r9   r   r   r   r   r   r      s    67  r   r   c                  R    ] tR t^%tR R ltR R ltR R ltR R ltR	 R
 ltRt	R# )ChanReceiverc                   V ^8  d   QhRR/# r"   r$   r
   r   )r&   s   "r   r'   ChanReceiver.__annotate__&   s    %%D%r   c                	   "   R # 5ir*   r   r8   s   &r   recvChanReceiver.recv&   s     #r/   c                   V ^8  d   QhRR/# r?   r   )r&   s   "r   r'   r@   (   s    &&T&r   c                	    R # r*   r   r8   s   &r   recv_nowaitChanReceiver.recv_nowait(   s    3r   c                   V ^8  d   QhRR/# r5   r   )r&   s   "r   r'   r@   *   r6   r   c                	    R # r*   r   r8   s   &r   r9   ChanReceiver.close*   r;   r   c                   V ^8  d   QhRR/# )r"   r$   zAsyncIterator[T_co]r   )r&   s   "r   r'   r@   ,   s    33.3r   c                	    R # r*   r   r8   s   &r   	__aiter__ChanReceiver.__aiter__,   s    r   c                   V ^8  d   QhRR/# r?   r   )r&   s   "r   r'   r@   .   s    ***r   c                	   "   R # 5ir*   r   r8   s   &r   	__anext__ChanReceiver.__anext__.   s     sr/   r   N)
r   r   r   r   rB   rF   r9   rM   rQ   r   r   r   r   r=   r=   %   s    %& 3**r   r=   c                      ] tR t^1tRR R lltR R ltR R ltR R	 ltR
 R ltR R lt	R R lt
]R R l4       tR R ltR R ltR R ltR R ltR R ltRtR# )ChanNc               $    V ^8  d   QhRRRRRR/# )r"   maxsizeintloopz asyncio.AbstractEventLoop | Noner$   r%   r   )r&   s   "r   r'   Chan.__annotate__2   s(     ( (( /( 
	(r   c                	   T;'       g    \         P                  ! 4       V n        \        V^ 4      V n        \         P
                  ! 4       V n        RV n        \        4       V n	        \        4       V n
        \        4       V n        R# )r   FN)asyncioget_event_loop_loopmax_maxsizeEvent	_close_ev_closedr   _gets_puts_queue)r,   rV   rX   s   &&&r   __init__Chan.__init__2   sX    
 55W335
GQ 6;g
6;g
 %r   c                    V ^8  d   QhRRRR/# )r"   waiterszdeque[asyncio.Future[T | None]]r$   r%   r   )r&   s   "r   r'   rY   @   s      $C  r   c                	    V'       d<   VP                  4       pVP                  4       '       d   K0  VP                  R 4       R # R # r*   )popleftdone
set_result)r,   ri   waiters   && r   _wakeup_nextChan._wakeup_next@   s2    __&F;;==!!$'	 r   c                    V ^8  d   QhRRRR/# r"   r#   r	   r$   r%   r   )r&   s   "r   r'   rY   G   s          d  r   c                	  "   V P                  4       '       dc   V P                  P                  4       '       gC   V P                  P	                  4       pV P
                  P                  V4        VG R j  xL
  Kx  V P                  V4       R #  L  \         d    h  TP                  4        \        P                  ! \        4      ;_uu_ 4        T P
                  P                  T4       R R R 4       M  + '       g   i     M; iT P                  4       '       g2   TP                  4       '       g   T P                  T P
                  4       h ; i5ir*   )fullra   is_setr]   create_futurerd   appendr   cancel
contextlibsuppress
ValueErrorremove	cancelledro   r2   )r,   r#   ps   && r   r-   	Chan.sendG   s     iikk$.."7"7"9"9

((*AJJa  	  
((44JJ%%a( 5444 yy{{1;;==%%djj1s]   EE5E/B 4B5B 9EB ?EC4+	E4D?EE3EEc                    V ^8  d   QhRRRR/# rr   r   )r&   s   "r   r'   rY   Z   s     & & &t &r   c                	    V P                   P                  4       '       d   \        hV P                  4       '       d   \        hV P
                  P                  V4       V P                  V P                  4       R # r*   )	ra   ru   r   rt   r   re   rw   ro   rc   r+   s   &&r   r2   Chan.send_nowaitZ   sO    >>  ""99;;N5!$**%r   c                   V ^8  d   QhRR/# r"   r$   r	   r   )r&   s   "r   r'   rY   d   s     " "A "r   c                	  "   V P                  4       '       dc   V P                  P                  4       '       gC   V P                  P	                  4       pV P
                  P                  V4        VG R j  xL
  Kx  V P!                  4       #  L  \         d    h \         d    TP                  4        \        P                  ! \        4      ;_uu_ 4        T P
                  P                  T4       R R R 4       M  + '       g   i     M; iT P                  4       '       g2   TP                  4       '       g   T P                  T P
                  4       h i ; i5ir*   )emptyra   ru   r]   rv   rc   rw   r   BaseExceptionrx   ry   rz   r{   r|   r}   ro   rF   )r,   gs   & r   rB   	Chan.recvd   s     jjll4>>#8#8#:#:

((*AJJa  !!    
((44JJ%%a( 5444 zz||AKKMM%%djj1sc   EE5E/B 4B5B 9EB E"3EC:1	E:D
E#E9EEc                   V ^8  d   QhRR/# r   r   )r&   s   "r   r'   rY   y   s     
 
Q 
r   c                	    V P                  4       '       d-   V P                  P                  4       '       d   \        h\        hV P
                  P                  4       pV P                  V P                  4       V# r*   )	r   ra   ru   r   r   re   rk   ro   rd   )r,   items   & r   rF   Chan.recv_nowaity   sV    ::<<~~$$&&  {{""$ 	$**%r   c                   V ^8  d   QhRR/# r5   r   )r&   s   "r   r'   rY      s     * *t *r   c                	   R V n         V P                  P                  4        V P                   F4  pVP	                  4       '       d   K  VP                  \        4       4       K6  	  \        V P                  4      V P                  4       8  dN   V P                  P                  4       pVP	                  4       '       d   KZ  VP                  \        4       4       Ku  V P                  '       d   V P                  V P                  4       K/  R# )TN)rb   ra   setrd   r}   set_exceptionr   lenrc   qsizepopro   )r,   puttergetters   &  r   r9   
Chan.close   s    jjF##%%$$Z\2 ! $**o

,ZZ^^%F##%%$$Z\2jjjdjj) r   c                   V ^8  d   QhRR/# r"   r$   boolr   )r&   s   "r   r'   rY      s       r   c                	    V P                   # r*   )rb   r8   s   &r   closedChan.closed   s    ||r   c                   V ^8  d   QhRR/# )r"   r$   rW   r   )r&   s   "r   r'   rY      s        s  r   c                ,    \        V P                  4      # )z<the number of elements queued (unread) in the channel buffer)r   re   r8   s   &r   r   
Chan.qsize   s    4;;r   c                   V ^8  d   QhRR/# r   r   )r&   s   "r   r'   rY      s     1 1d 1r   c                	b    V P                   ^ 8:  d   R# V P                  4       V P                   8  # )r   F)r_   r   r8   s   &r   rt   	Chan.full   s&    ==A::<4==00r   c                   V ^8  d   QhRR/# r   r   )r&   s   "r   r'   rY      s      t r   c                	$    V P                   '       * # r*   )re   r8   s   &r   r   
Chan.empty   s    ;;r   c                   V ^8  d   QhRR/# )r"   r$   zAsyncIterator[T]r   )r&   s   "r   r'   rY      s      + r   c                	    V # r*   r   r8   s   &r   rM   Chan.__aiter__   s    r   c                   V ^8  d   QhRR/# r   r   )r&   s   "r   r'   rY      s     / / /r   c                	l   "    V P                  4       G R j  xL
 #  L  \         d	    \        R hi ; i5ir*   )rB   r   StopAsyncIterationr8   s   &r   rQ   Chan.__anext__   s2     	/$$$ 	/$$.	/s    4  4 14)ra   rb   rc   r]   r_   rd   re   )r   N)r   r   r   r   rf   ro   r-   r2   rB   rF   r9   propertyr   r   rt   r   rM   rQ   r   r   r   r   rT   rT   1   sW    ( &&"*
*$   1/ /r   rT   )
__future__r   r[   ry   collectionsr   collections.abcr   typingr   r   r   r	   r
   r   	Exceptionr   r   r   r   r=   rT   r   r   r   <module>r      s    "    ) - -CLv&:T2	 		y 			 	!(# !	+8D> 	+A/71: A/r   