+
    ~j
                       ^ RI Ht ^ RIt^ RIt^ RIHtHtHtHt ^RI	H
t
  ! R R]4      t] ! R R]]4      4       t]]]],          3,          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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tR% R& ltR' R( lt R) R* lt!R+ R, lt"R- R. lt#R/ R0 lt$R# )1    )annotationsN)ClassVarProtocolcastruntime_checkable)utilsc                  "    ] tR t^
t$ R]R&   RtR# )MessagezClassVar[int]MSG_ID N)__name__
__module____qualname____firstlineno____annotations____static_attributes__r       o/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/livekit/agents/ipc/channel.pyr
   r
   
   s    r   r
   c                  .    ] tR t^tR R ltR R ltRtR# )DataMessagec                    V ^8  d   QhRRRR/#    b
io.BytesIOreturnNoner   )formats   "r   __annotate__DataMessage.__annotate__   s    //z/d/r   c                	    R # Nr   selfr   s   &&r   writeDataMessage.write   s    Cr   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r   r   r       s    ..j.T.r   c                	    R # r"   r   r#   s   &&r   readDataMessage.read   s    3r   r   N)r   r   r   r   r%   r)   r   r   r   r   r   r      s    /..r   r   c               $    V ^8  d   QhRRRRRR/# )r   databytesmessagesMessagesDictr   r
   r   )r   s   "r   r   r      s!        ' r   c                    \         P                  ! V 4      p\        V4      pW,          ! 4       p\        V\        4      '       d   VP                  V4       V# r"   )ioBytesIOread_int
isinstancer   r)   )r,   r.   biomsg_idmsgs   &&   r   _read_messager8      sA    
**T
Cc]F


C#{##Jr   c                    V ^8  d   QhRRRR/# )r   r7   r
   r   r-   r   )r   s   "r   r   r   "   s       E r   c                    \         P                  ! 4       p\        WP                  4       \	        V \
        4      '       d   V P                  V4       VP                  4       # r"   )r1   r2   	write_intr   r4   r   r%   getvalue)r7   r5   s   & r   _write_messager=   "   s=    
**,Cc::#{##		#<<>r   c               $    V ^8  d   QhRRRRRR/# )r   dplx"utils.aio.duplex_unix._AsyncDuplexr.   r/   r   r
   r   )r   s   "r   r   r   ,   s$     < <
,<8D<<r   c                R   "   \        V P                  4       G R j  xL
 V4      #  L	5ir"   r8   
recv_bytesr?   r.   s   &&r   arecv_messagerE   ,   s!      t00(;;0s   '%
'c               $    V ^8  d   QhRRRRRR/# )r   r?   r@   r7   r
   r   r   r   )r   s   "r   r   r   2   s#     / /@ /w /SW /r   c                V   "   V P                  \        V4      4      G R j  xL
  R #  L5ir"   
send_bytesr=   r?   r7   s   &&r   asend_messagerK   2   s     
//.-
...s   )')c               $    V ^8  d   QhRRRRRR/# )r   r?   utils.aio.duplex_unix._Duplexr.   r/   r   r
   r   )r   s   "r   r   r   6   s#     6 64 6 6QX 6r   c                6    \        V P                  4       V4      # r"   rB   rD   s   &&r   recv_messagerO   6   s    *H55r   c               $    V ^8  d   QhRRRRRR/# )r   r?   rM   r7   r
   r   r   r   )r   s   "r   r   r   :   s"     ) )4 )7 )t )r   c                :    V P                  \        V4      4       R # r"   rH   rJ   s   &&r   send_messagerR   :   s    OON3'(r   c               $    V ^8  d   QhRRRRRR/# )r   r   r   bufr-   r   r   r   )r   s   "r   r   r   >   s!      : E d r   c                |    V P                  \        V4      P                  ^R4      4       V P                  V4       R# )   bigN)r%   lento_bytes)r   rT   s   &&r   write_bytesrZ   >   s*    GGCHa'(GGCLr   c                    V ^8  d   QhRRRR/# )r   r   r   r   r-   r   )r   s   "r   r   r   C   s      *  r   c                n    \         P                  V P                  ^4      R4      pV P                  V4      # )rV   rW   int
from_bytesr)   r   lengths   & r   
read_bytesrb   C   s(    ^^AFF1Iu-F66&>r   c               $    V ^8  d   QhRRRRRR/# )r   r   r   sstrr   r   r   )r   s   "r   r   r   H   s!      J 3 4 r   c                    VP                  R 4      pV P                  \        V4      P                  ^R4      4       V P                  V4       R# )utf-8rW   N)encoder%   rX   rY   )r   rd   encodeds   && r   write_stringrj   H   s9    hhwGGGCL!!!U+,GGGr   c                    V ^8  d   QhRRRR/# )r   r   r   r   re   r   )r   s   "r   r   r   N   s     * *: *# *r   c                    \         P                  V P                  ^4      R4      pV P                  V4      P                  R4      # )rV   rW   rg   )r^   r_   r)   decoder`   s   & r   read_stringrn   N   s3    ^^AFF1Iu-F66&>  ))r   c               $    V ^8  d   QhRRRRRR/# )r   r   r   ir^   r   r   r   )r   s   "r   r   r   S   s!     / / / / /r   c                L    V P                  VP                  ^RRR7      4       R# )rV   rW   TsignedNr%   rY   )r   rp   s   &&r   r;   r;   S   s    GGAJJq%J-.r   c                    V ^8  d   QhRRRR/# r   r   r   r   r^   r   )r   s   "r   r   r   W   s     9 9
 9s 9r   c                P    \         P                  V P                  ^4      RRR7      # )rV   rW   Trr   r]   r   s   &r   r3   r3   W   s    >>!&&)U4>88r   c               $    V ^8  d   QhRRRRRR/# )r   r   r   biboolr   r   r   )r   s   "r   r   r   [   s!     # #* #$ #4 #r   c                H    V P                  VP                  ^R4      4       R# )   rW   Nrt   )r   rz   s   &&r   
write_boolr~   [   s    GGBKK5!"r   c                    V ^8  d   QhRRRR/# )r   r   r   r   r{   r   )r   s   "r   r   r   _   s     - - - -r   c                L    \         P                  V P                  ^4      R4      # )r}   rW   )r{   r_   r)   rx   s   &r   	read_boolr   _   s    ??166!9e,,r   c               $    V ^8  d   QhRRRRRR/# )r   r   r   ffloatr   r   r   )r   s   "r   r   r   c   s!     ! !: !% !D !r   c                R    V P                  \        P                  ! R V4      4       R# )r   Nr%   structpack)r   r   s   &&r   write_floatr   c       GGFKKQ r   c                    V ^8  d   QhRRRR/# r   r   r   r   r   r   )r   s   "r   r   r   g   s     9 9* 9 9r   c           	     x    \        \        \        P                  ! R V P	                  ^4      4      ^ ,          4      # )r   r   r   r   unpackr)   rx   s   &r   
read_floatr   g   '    v}}S!&&)4Q788r   c               $    V ^8  d   QhRRRRRR/# )r   r   r   dr   r   r   r   )r   s   "r   r   r   k   s!     ! !J !5 !T !r   c                R    V P                  \        P                  ! R V4      4       R# )r   Nr   )r   r   s   &&r   write_doubler   k   r   r   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r   r   r   o   s     9 9: 9% 9r   c           	     x    \        \        \        P                  ! R V P	                  ^4      4      ^ ,          4      # )r   r   rx   s   &r   read_doubler   o   r   r   c               $    V ^8  d   QhRRRRRR/# )r   r   r   longr^   r   r   r   )r   s   "r   r   r   s   s!     % %* %C %D %r   c                H    V P                  VP                  ^R4      4       R# )   rW   Nrt   )r   r   s   &&r   
write_longr   s   s    GGDMM!U#$r   c                    V ^8  d   QhRRRR/# rv   r   )r   s   "r   r   r   w   s     , , , ,r   c                L    \         P                  V P                  ^4      R4      # )r   rW   r]   rx   s   &r   	read_longr   w   s    >>!&&)U++r   )%
__future__r   r1   r   typingr   r   r   r    r   r
   r   dictr^   typer/   r8   r=   rE   rK   rO   rR   rZ   rb   rj   rn   r;   r3   r~   r   r   r   r   r   r   r   r   r   r   <module>r      s    " 	  > > h  /'8 / / Cg&'</6)

*
/9#-!9!9%,r   