+
    ~j                    t    ^ RI Ht ^ RIt^ RIt^ RIt ! R R]4      t ! R R4      tR R lt ! R	 R
4      t	R# )    )annotationsNc                      ] tR t^tRtRtR# )DuplexClosedz6Exception raised when the duplex connection is closed. N)__name__
__module____qualname____firstlineno____doc____static_attributes__r       y/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/livekit/agents/utils/aio/duplex_unix.pyr   r      s    @r   r   c                  `    ] tR t^tRR R llt]R R l4       tR R ltR R	 ltR
 R lt	Rt
R# )_AsyncDuplexNc          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )   socksocket.socketreaderzasyncio.StreamReaderwriterzasyncio.StreamWriterloopz asyncio.AbstractEventLoop | NonereturnNoner   )formats   "r   __annotate___AsyncDuplex.__annotate__   s<     
 

 %
 %	

 /
 

r   c                	6    W@n         Wn        W n        W0n        R # N)_loop_sock_reader_writer)selfr   r   r   r   s   &&&&&r   __init___AsyncDuplex.__init__   s     

r   c                    V ^8  d   QhRRRR/# )r   r   r   r   r   r   )r   s   "r   r   r      s     8 8 8< 8r   c                	   "   \         P                  ! 4       p\         P                  ! V R 7      G Rj  xL
 w  r#\        WW14      #  L5i)r   N)asyncioget_running_loopopen_connectionr   )r   r   r   r   s   &   r   open_AsyncDuplex.open   s;     '')&66DAAD&77 Bs   0AAAc                   V ^8  d   QhRR/# r   r   bytesr   )r   s   "r   r   r   !   s     
( 
(% 
(r   c                	B  "    V P                   P                  ^4      G Rj  xL
 p\        P                  ! RV4      ^ ,          pV P                   P                  V4      G Rj  xL
 #  LE L  \        \
        \        P                  3 d   p\        4       ThRp?ii ; i5i)   N!I)	r!   readexactlystructunpackOSErrorEOFErrorr)   IncompleteReadErrorr   r#   	len_byteslenes   &   r   
recv_bytes_AsyncDuplex.recv_bytes!   s     		("ll66q99I--i03C11#666 :6''
 	(
 .a'	(sK   BA, A(A A, #A*$A, 'B(A, *A, , BBBBc                    V ^8  d   QhRRRR/# r   datar0   r   r   r   )r   s   "r   r   r   -   s     ( (U (t (r   c                	@  "    \         P                  ! R \        V4      4      pV P                  P	                  V4       V P                  P	                  V4       V P                  P                  4       G Rj  xL
  R#  L  \         d   p\        4       ThRp?ii ; i5i)r3   N)r5   packr<   r"   writedrainr7   r   r#   rB   r;   r=   s   &&  r   
send_bytes_AsyncDuplex.send_bytes-   sq     	(D#d)4ILLy)LLt$,,$$&&& 	(.a'	(s;   BA3B  7A>8B  <B>B   BBBBc                   V ^8  d   QhRR/# r   r   r   r   )r   s   "r   r   r   6   s     ( (d (r   c                	   "    V P                   P                  4        V P                   P                  4       G R j  xL
  V P                  P                  4        R #  L   \         d   p\        4       ThR p?ii ; i5ir   )r"   closewait_closedr    r7   r   r#   r=   s   & r   aclose_AsyncDuplex.aclose6   s^     	(LL ,,**,,,JJ - 	(.a'	(s8   A<7A AA A<A A9)A44A99A<)r   r!   r    r"   r   )r   r   r	   r
   r$   staticmethodr,   r>   rH   rP   r   r   r   r   r   r      s/    
 8 8

((( (r   r   c               $    V ^8  d   QhRRRRRR/# )r   r   r   	num_bytesintr   r0   r   )r   s   "r   r   r   ?   s!       # % r   c                    \        4       p\        V4      V8  dG   V P                  V\        V4      ,
          4      pV'       g   \        4       hVP	                  V4       KV  \        V4      # r   )	bytearrayr<   recvr8   extendr0   )r   rT   rB   packets   &&  r   _read_exactlyr[   ?   sM    ;D
d)i
9s4y01*F;r   c                  h    ] tR t^It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tR# )_Duplexc                    V ^8  d   QhRRRR/# )r   r   r   r   r   r   )r   s   "r   r   _Duplex.__annotate__J   s     0 0] 0t 0r   c                	    Wn         R # r   r    r#   r   s   &&r   r$   _Duplex.__init__J   s    +/
r   c                    V ^8  d   QhRRRR/# )r   r   r   r   r]   r   )r   s   "r   r   r_   N   s      = W r   c                	    \        V 4      # r   )r]   r(   s   &r   r,   _Duplex.openM   s    t}r   c                   V ^8  d   QhRR/# r/   r   )r   s   "r   r   r_   Q   s     	( 	(E 	(r   c                	   V P                   f   \        4       h \        V P                   ^4      p\        P                  ! RV4      ^ ,          p\        V P                   V4      #   \
        \        3 d   p\        4       ThR p?ii ; iNr3   )r    r   r[   r5   r6   r7   r8   r:   s   &   r   r>   _Duplex.recv_bytesQ   sn    ::. 	(%djj!4I--i03C S11" 	(.a'	(s   A	A$ $B5B  Bc                    V ^8  d   QhRRRR/# rA   r   )r   s   "r   r   r_   \   s     	( 	(u 	( 	(r   c                	    V P                   f   \        4       h \        P                  ! R\	        V4      4      pV P                   P                  V4       V P                   P                  V4       R #   \         d   p\        4       ThR p?ii ; iri   )r    r   r5   rD   r<   sendallr7   rG   s   &&  r   rH   _Duplex.send_bytes\   sk    ::. 	(D#d)4IJJy)JJt$ 	(.a'	(s   AA2 2B=BBc                   V ^8  d   QhRR/# )r   r   r   r   )r   s   "r   r   r_   g   s       r   c                	\    V P                   f   \        4       hV P                   pR V n         V# r   )r    r   rb   s   & r   detach_Duplex.detachg   s)    ::. zz
r   c                   V ^8  d   QhRR/# rK   r   )r   s   "r   r   r_   o   s     ( (t (r   c                	     V P                   e$   V P                   P                  4        R V n         R # R #   \         d   p\        4       ThR p?ii ; ir   )r    rM   r7   r   rO   s   & r   rM   _Duplex.closeo   sI    	(zz%

  "!
 &  	(.a'	(s   /5 A AAra   N)r   r   r	   r
   r$   rR   r,   r>   rH   rq   rM   r   r   r   r   r]   r]   I   s4    0  	(	(( (r   r]   )

__future__r   r)   socketr5   	Exceptionr   r   r[   r]   r   r   r   <module>ry      s7    "   	9 	.( .(b,( ,(r   