+ ~jD3ca0t$^RIHt^RIt^RIHuHt^RI t ^RI t ^RI H t ^RI HtHtHt^RIHt^RIHt^RIHtHt^RI Ht^R IHtHtHt^R IHt^R IH t H!t!H"t"^R I#H$t$H%t%H&t&^R I'H(t(])],],t*R]+R&],])]-3,t.R]+R&].]),t/R]+R&],]0].3,t1R]+R&],]0])3,t2R]+R&]!R4t3] Ph3RRRR/RRlllt5!RR]!4t6!RR] 4t7!RR]$]74t8!R R!]84t9!R"R#]%]8,]74t:!R$R%]&]1,]74t;!R&R']&]0,]74t<!R(R)]&]2,]74t=!R*R+]&]0,]74t>R#),) annotationsN)abstractmethod)Callable CollectionMapping)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily)Any TypeAliasTypeVar)get_async_backend)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupr IPAddressTypeIPSockAddrType SockAddrType UDPPacketTypeUNIXDatagramPacketTypeT_Retvalrequire_connectedF require_boundc 0V^8dQhRRRRRRRRR RR R /#)  sock_or_fdsocket.socket | int sock_typezsocket.SocketKind addr_familyzsocket.AddressFamilyrboolrreturn socket.socket)formats"g/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/anyio/abc/_sockets.py __annotate__r+sLBB#B B&B  B  BBc\V\4'd\P!VR7pME\V\P4'dTpM"\R\V4P R24hV'dVP4V'dmVP\P\P39dVP4^,pMVP4pV'g \ R4hV\P8wdAVPV8wd0\ RVP RVPP 24hVPV8wd0\ R VP RVPP 24hTP'R 4T# \dZpTP\P 8Xd \ R4ThT'd \ R4ThT'd \ R4ThhRp?ii;i \dp\ R4ThRp?ii;i \dRpELRi;i \"d)\T\4'dTP%4hi;i) )filenoz.the file descriptor does not refer to a socketzthe socket must be connectedz+the socket must be bound to a local addressNzexpected an int or socket, got z insteadz"address family mismatch: expected z, got zsocket type mismatch: expected F) isinstanceintsocketOSErrorerrnoENOTSOCK ValueError TypeErrortype __qualname__ getpeernamefamilyAF_INETAF_INET6 getsockname AF_UNSPECname BaseExceptiondetach setblocking)r!r#r$rrsockexc bound_addrs&&&$$ r*_validate_socketrFs+*c"" == 3D J . .-d:.>.K.K-LH U  "  J  "  ";;6>>6??"CC!%!1!1!3A!6J!%!1!1!3J !NOO &** *t{{k/I4[5E5E4Ff;;##$&  99 !1)..1A GWX  " U Ko yyENN* D# !?@cI !NOUXX , J !?@cI J "!  "  j# & & KKM sF,6I?HIAH2IH2/I8B I, H72H *H > H  H H/ H**H//I2 I?III3I9c]tRt^ct$Rt]!4tR]R&]!4tR]R&]!4t R]R&]!4t R]R &]!4t R]R &]!4t R]R &R t R #)SocketAttributea .. attribute:: family :type: socket.AddressFamily the address family of the underlying socket .. attribute:: local_address :type: tuple[str, int] | str the local address the underlying socket is connected to .. attribute:: local_port :type: int for IP based sockets, the local port the underlying socket is bound to .. attribute:: raw_socket :type: socket.socket the underlying stdlib socket object .. attribute:: remote_address :type: tuple[str, int] | str the remote address the underlying socket is connected to .. attribute:: remote_port :type: int for IP based sockets, the remote port the underlying socket is connected to r r:r local_addressr0 local_portr' raw_socketremote_address remote_portr(N)__name__ __module__r8__firstlineno____doc__rr:__annotations__rIrJrKrLrM__static_attributes__r(r,r*rHrHcsX@,-FM-"1"3M<3%'J' / 1J 1#2#4NL4&(K(r,rHcL]tRt^t]RRl4t]]RRl44tRtR#)_SocketProvidercV^8dQhRR/#)r r&zMapping[Any, Callable[[], Any]]r()r)s"r*r+_SocketProvider.__annotate__s"Ar,c aaaa^RIHo\PV3Rl\PVV3Rl\P V3Rl/pS!SP P44oSeV3RlV\P&SP P\P\P39d<V3RlV\P&Se!S^,oV3RlV\P&V# \dRoLi;i) r )convert_ipv6_sockaddrc0<SPP#N) _raw_socketr:selfsr*2_SocketProvider.extra_attributes..sD,<,<,C,Cr,cD<S!SPP44#r[r\r=)convertr^sr*r_r`s7  ,,.4r,c<SP#r[)r\r]sr*r_r`s 0@0@r,Nc<S#r[r()peernamesr*r_r`sr,cF<SPP4^,#)rbr]sr*r_r`s  ,,.q1r,c<S#r[r()rMsr*r_r`s+r,)_core._socketsrYrHr:rIrKr\r9r2rLr r;r<rJrM)r^ attributesrcrfrMsf @@@r*extra_attributes _SocketProvider.extra_attributessE  " "$C  ) ),  & &(@ 4  /6t7G7G7S7S7U/VH  9IJ55 6    " "}'<'T>T&U U6J11 2#&qk :M ?667! H s C<< D  D cV^8dQhRR/#)r r&r'r()r)s"r*r+rWs  ] r,c R#r[r(r]s&r*r\_SocketProvider._raw_sockets r,r(N) rNrOr8rPpropertyrlrr\rSr(r,r*rUrUs0 <  r,rUc0]tRt^tRt]RRl4tRtR#) SocketStreamzi Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c V^8dQhRRRR/#)r r!r"r&rsr()r)s"r*r+SocketStream.__annotate__s B B+> B< Br,c "\V\PRR7p\4P V4GRjxL #L5i)a Wrap an existing socket object or file descriptor as a socket stream. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must already be connected. :param sock_or_fd: a socket object or file descriptor :return: a socket stream TrN)rFr1 SOCK_STREAMrwrap_stream_socketclsr!rCs&& r* from_socketSocketStream.from_sockets6 F,>,>RVW&(;;DAAAA9AAAr(NrNrOr8rPrQ classmethodr|rSr(r,r*rsrss  B Br,rscX]tRt^t]RRl4t]RRl4t]RRl4tRt R#) UNIXSocketStreamc V^8dQhRRRR/#)r r!r"r&rr()r)s"r*r+UNIXSocketStream.__annotate__s GG+>GCSGr,c "\V\P\PRR7p\ 4P V4GRjxL #L5i)a" Wrap an existing socket object or file descriptor as a UNIX socket stream. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must already be connected. :param sock_or_fd: a socket object or file descriptor :return: a UNIX socket stream TrwN)rFr1rxAF_UNIXrwrap_unix_stream_socketrzs&& r*r|UNIXSocketStream.from_sockets@ **FNNd '(@@FFFFAA A Ac$V^8dQhRRRRRR/#)r messagebytesfdszCollection[int | IOBase]r&Noner()r)s"r*r+rs"  e 2J t r,c "R#5i)z Send file descriptors along with a message to the peer. :param message: a non-empty bytestring :param fds: a collection of files (either numeric file descriptors or open file or socket objects) Nr()r^rrs&&&r*send_fdsUNIXSocketStream.send_fdsc$V^8dQhRRRRRR/#)r msglenr0maxfdsr&ztuple[bytes, list[int]]r()r)s"r*r+rs"   S =T r,c "R#5i)z Receive file descriptors along with a message from the peer. :param msglen: length of the message to expect from the peer :param maxfds: maximum number of file descriptors to expect from the peer :return: a tuple of (message, file descriptors) Nr()r^rrs&&&r* receive_fdsUNIXSocketStream.receive_fdsrrr(N) rNrOr8rPrr|rrrrSr(r,r*rrs>GG     r,rcV]tRt^tRt]RRl4t]RRl4tR RRllt R t R#) SocketListenerzq Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. c V^8dQhRRRR/#)r r!r"r&rr()r)s"r*r+SocketListener.__annotate__s"DD'D Dr,c "\V\PRR7p\4P V4GRjxL #L5i)z Wrap an existing socket object or file descriptor as a socket listener. The newly created listener takes ownership of the socket being passed in. :param sock_or_fd: a socket object or file descriptor :return: a socket listener TrN)rFr1rxrwrap_listener_socketrzs&& r*r|SocketListener.from_sockets5 F,>,>dS&(==dCCCCr~cV^8dQhRR/#)r r&rsr()r)s"r*r+r s--l-r,c "R#5i)zAccept an incoming connection.Nr(r]s&r*acceptSocketListener.acceptrrNc$V^8dQhRRRRRR/#)r handlerzCallable[[SocketStream], Any] task_groupzTaskGroup | Noner&rr()r)s"r*r+r s( 7 7. 7% 7  7r,c ."^RIHp\4;_uu_4GRjxL pVfVPV!44GRjxL pVP 4GRjxL pVP W4K,LRL2L +GRjxL 'giR#;i5i)r )create_task_groupN)rrenter_async_contextr start_soon)r^rrrstackstreams&&& r*serveSocketListener.serve so )!###u!#(#<#<=N=P#QQ #{{},%%g6 $Q- $###s\BA2BA8A4A8A6A82B4A86A88B >B? B B Br(r[) rNrOr8rPrQrr|rrrrSr(r,r*rrs; DD -- 7 7r,rc<]tRtRtRt]RRl4tRRltRtR#) UDPSocketizo Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c V^8dQhRRRR/#)r r!r"r&rr()r)s"r*r+UDPSocket.__annotate__$s ? ?+> ?9 ?r,c "\V\PRR7p\4P V4GRjxL #L5i)a Wrap an existing socket object or file descriptor as a UDP socket. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must be bound to a local address. :param sock_or_fd: a socket object or file descriptor :return: a UDP socket TrN)rFr1 SOCK_DGRAMrwrap_udp_socketrzs&& r*r|UDPSocket.from_socket#s5 F,=,=TR&(88>>>>r~c(V^8dQhRRRRRRRR/#) r datarhoststrportr0r&rr()r)s"r*r+r2s(555c555r,c F"VPWV334GRjxL #L5i)zN Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)r^rrrs&&&&r*sendtoUDPSocket.sendto2s# YYTl34444s !!r(N rNrOr8rPrQrr|rrSr(r,r*rrs%  ? ?55r,rc0]tRtRtRt]RRl4tRtR#)ConnectedUDPSocketi:zm Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c V^8dQhRRRR/#)r r!r"r&rr()r)s"r*r+ConnectedUDPSocket.__annotate__Bs II+>ICUIr,c "\V\PRR7p\4P V4GRjxL #L5i)a& Wrap an existing socket object or file descriptor as a connected UDP socket. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must already be connected. :param sock_or_fd: a socket object or file descriptor :return: a connected UDP socket TrwN)rFr1rrwrap_connected_udp_socketrzs&& r*r|ConnectedUDPSocket.from_socketAs<    "  '(BB4HHHHr~r(Nrr(r,r*rr:s IIr,rc<]tRtRtRt]RRl4tRRltRtR#) UNIXDatagramSocketiUzy Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c V^8dQhRRRR/#)r r!r"r&rr()r)s"r*r+UNIXDatagramSocket.__annotate___s"II'I Ir,c "\V\P\P4p\ 4P V4GRjxL #L5i)z Wrap an existing socket object or file descriptor as a UNIX datagram socket. The newly created socket wrapper takes ownership of the socket being passed in. :param sock_or_fd: a socket object or file descriptor :return: a UNIX datagram socket N)rFr1rrrwrap_unix_datagram_socketrzs&& r*r|UNIXDatagramSocket.from_socket^s9 F,=,=v~~N&(BB4HHHHsAAA  Ac$V^8dQhRRRRRR/#)r rrpathrr&rr()r)s"r*r+rps!---c-d-r,c B"VPW34GRjxL #L5i)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)r^rrs&&&r*rUNIXDatagramSocket.sendtopsYY|,,,,s r(Nrr(r,r*rrUs' II"--r,rc0]tRtRtRt]RRl4tRtR#)ConnectedUNIXDatagramSocketiuzv Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c V^8dQhRRRR/#)r r!r"r&rr()r)s"r*r+(ConnectedUNIXDatagramSocket.__annotate__}s"SS'S %Sr,c "\V\P\PRR7p\ 4P V4GRjxL #L5i)a: Wrap an existing socket object or file descriptor as a connected UNIX datagram socket. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must already be connected. :param sock_or_fd: a socket object or file descriptor :return: a connected UNIX datagram socket TrwN)rFr1rrr#wrap_connected_unix_datagram_socketrzs&& r*r|'ConnectedUNIXDatagramSocket.from_socket|s@  ))6>>T '(LLTRRRRrr(Nrr(r,r*rrus SSr,r)?__conditional_annotations__ __future__rbuiltins @py_builtins_pytest.assertion.rewrite assertionrewrite @pytest_arr3r1abcrcollections.abcrrr contextlibrior ipaddressr r r typingr r r_core._eventloopr_core._typedattrrrr_streamsrrr_tasksrrrrRtupler0rrrrrrr>rFrHrUrsrrrrrr)rs@r*rs"" 99%. **0 CB,{: y:!#s(O +(3. i. !67 y7$)%*$5 5 :  )/(8(8B $ B  BBJ&)'&)R# ,# LB:B.$ |$ N)7Xl+_)7X5&}55<I/6I6-12O-@S"8"?Sr,