+
    ~j|                         ^ RI t ^ RIHt ^ RIHtHtHtHt ^ RIH	t	H
t
HtHtHtHt ^ RIHt ] ! R R]4      4       t]! R4      tR	 R
 lt ! R R]
],          4      t]tR# )    N)deque)AsyncGeneratorAsyncIterableAsyncIteratorIterator)AnyGenericProtocolTypeVaroverloadruntime_checkable)AsyncContextManagerc                   2   a  ] tR t^t o V 3R lR ltRtV tR# )_ACloseablec                   < V ^8  d   QhRR/#    returnN )format__classdict__s   "w/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/livekit/agents/utils/aio/itertools.py__annotate___ACloseable.__annotate__   s     / /d /    c                   "   R# 5i)z Asynchronously close this objectNr   selfs   &r   aclose_ACloseable.aclose   s        r   N)__name__
__module____qualname____firstlineno__r   __static_attributes____classdictcell__r   s   @r   r   r      s     / /r   r   Tc                   V ^8  d   QhR\         \        ,          R\        \        ,          R\        \        \        ,          ,          R\        \
        ,          R\        \        R,          ,          R\        \        R3,          /# )r   iteratorbufferpeerslock	exceptionNr   )r   r)   r   listr   r   BaseExceptionr   )r   s   "r   r   r      sm     .$ .$A.$!H.$ a>.$ c
"	.$
 MD().$ AtG.$r   c                  "     V'       g   T;_uu_4       GRj  xL
  V'       d    RRR4      GRj  xL
  K7  V^ ,          e
   V^ ,          h V P                  4       G Rj  xL
 pV F  pVP                  V4       K  	  RRR4      GRj  xL
  VP                  4       5x  K   L Lt LG  \         d     RRR4      GRj  xL 
  MJ\        P                   d    h \
         d   pYt^ &   h Rp?ii ; i Li  + GRj  xL 
 '       g   i     L; i\        T4       F  w  rYaJ g   K  TP                  T4        M	  T'       g4   \        T \        4      '       d   T P                  4       G Rj  xL 
  R# R# R#   \        T4       F  w  rYaJ g   K  TP                  T4        M	  T'       g2   \        T \        4      '       d   T P                  4       G Rj  xL 
  i i i ; i5i)TN)	__anext__appendStopAsyncIterationasyncioCancelledErrorr1   popleft	enumeratepop
isinstancer   r   )	r+   r,   r-   r.   r/   itempeer_buffereidxs	   &&&&&    r   tee_peerr@      s|    $44   44 !|/'l*5%-%7%7%99 ,1K'..t4 ,1%  4( .."")    :-   44 #11  ( '(!  444, !*% 0C$		# !1
 Hk:://### ;u !*% 0C$		# !1
 Hk:://### ;us  G(E> E> B'E> 
C9E> B)E> C9B-#B+$B-(C9E> C7E> )E> +B--C48C99E> CE> C4
C4)C4*C//C44C97E> 9D	?D 
D	D	E> G(,G(	)G(2E53G(>G%G%3)G%GG%%G(c                      a  ] tR t^Et o RtRV 3R lR lltV 3R lR lt]V 3R lR l4       t]V 3R lR l4       tV 3R	 lR
 ltV 3R lR lt	V 3R lR lt
V 3R lR ltV 3R lR ltRtV tR# )Teec                6   < V ^8  d   QhRS[ S[,          RS[/# )r   r+   n)r   r)   int)r   r   s   "r   r   Tee.__annotate__H   s$     
 
"
 
r   c                l  a aa VP                  4       S n        \        V4       Uu. uF  p\        4       NK  	  upS n        \
        P                  ! 4       oR .o\        ;QJ d*    . VVV 3R lS P                   4       F  NK  	  5S n        R # ! VVV 3R lS P                   4       4      S n        R # u upi )Nc           	   3   l   <"   T F)  p\        SP                  VSP                  SSR 7      x  K+  	  R# 5i))r+   r,   r-   r.   r/   N)r@   	_iterator_buffers).0r,   r/   r.   r   s   & r   	<genexpr>Tee.__init__.<locals>.<genexpr>R   s=      	
 ( mm#  (s   14)		__aiter__rI   ranger   rJ   r6   Locktuple	_children)r   r+   rD   _r/   r.   s   f&& @@r   __init__Tee.__init__H   s    
 "++-:?((C(Q((C||~15	 	
 --	
 	
 --	
 	
	 )Ds   B1c                    < V ^8  d   QhRS[ /# r   r   )rE   )r   r   s   "r   r   rF   ]   s     # # #r   c                ,    \        V P                  4      # N)lenrR   r   s   &r   __len__Tee.__len__]   s    4>>""r   c                6   < V ^8  d   QhRS[ RS[S[,          /# )r   r<   r   )rE   r   r)   )r   r   s   "r   r   rF   a   s    ===a(8=r   c                    R # rY   r   r   r<   s   &&r   __getitem__Tee.__getitem__`   s    :=r   c                J   < V ^8  d   QhRS[ RS[S[S[,          R3,          /# r   r<   r   .)slicerQ   r   r)   )r   r   s   "r   r   rF   d   s"    KKK%a0@#0E*FKr   c                    R # rY   r   r_   s   &&r   r`   ra   c   s    HKr   c                z   < V ^8  d   QhRS[ S[,          RS[S[,          S[S[S[,          R3,          ,          /# rc   )rE   rd   r   r)   rQ   )r   r   s   "r   r   rF   f   s:     $ $e $a0@5WXIY[^I^C_0_ $r   c                (    V P                   V,          # rY   rR   r_   s   &&r   r`   ra   f   s    ~~d##r   c                @   < V ^8  d   QhRS[ S[S[,          ,          /# rW   )r   r   r)   )r   r   s   "r   r   rF   i   s     " "(=#34 "r   c              #  :   "   V P                    R j  xL
  R #  L5irY   rh   r   s   &r   __iter__Tee.__iter__i   s     >>!!s   c                   < V ^8  d   QhRR/# )r   r   zTee[T]r   )r   r   s   "r   r   rF   l   s      ( r   c                   "   V # 5irY   r   r   s   &r   
__aenter__Tee.__aenter__l   s
     r!   c                0   < V ^8  d   QhRS[ RS[ RS[ RR/# )r   exc_typeexc_valexc_tbr   N)r   )r   r   s   "r   r   rF   o   s)       c 3 4 r   c                B   "   V P                  4       G R j  xL
  R #  L5irY   )r   )r   rr   rs   rt   s   &&&&r   	__aexit__Tee.__aexit__o   s     kkms   c                   < V ^8  d   QhRR/# r   r   )r   r   s   "r   r   rF   r   s      d r   c                @  "   V P                    F  p VP                  4       G R j  xL
  K  	  \        V P                  \
        4      '       d&    V P                  P                  4       G R j  xL
  R # R #  LO  \         d     Kw  i ; i L  \         d     R # i ; i5irY   )rR   r   	Exceptionr;   rI   r   )r   childs   & r   r   
Tee.acloser   s     ^^Elln$$ $ dnnk22nn++--- 3	 % 
 . sm   BA8A6A8$BB -B
.B 2B6A88BBBB
B BBBB)rJ   rR   rI   N)rI   rJ   rR   )r   )r"   r#   r$   r%   	__slots__rT   r[   r   r`   rk   ro   rv   r   r&   r'   r(   s   @r   rB   rB   E   sn     6I
 
*# # = =K K$ $" "   r   rB   )r6   collectionsr   collections.abcr   r   r   r   typingr   r	   r
   r   r   r   typing_extensionsr   r   r)   r@   rB   teer   r   r   <module>r      s^      R R O O 1
 /( / /
 CL.$b8'!* 8v 
r   