+ NV-jD3a0t$^RIHt^RIt^RIt^RIHt^RIHtH t H t ^RI H t ^RI Ht^RIHtHt^RIHt^R IHtHtHt^R IHt^R IHtHtHt^R IHtHtH t ^R I!H"t"]#],],t$R]%R&]&]#]'3,t(R]%R&](]#,t)R]%R&]&]*](3,t+R]%R&]&]*]#3,t,R]%R&]!R4t-]P\3RRRR/RRlllt/!RR]4t0!RR]4t1!RR]]14t2!R R!]24t3!R"R#]]2,]14t4!R$R%] ]+,]14t5!R&R'] ]*,]14t6!R(R)] ],,]14t7!R*R+] ]*,]14t8R#),) 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"c/Volumes/fast/ai/experiments/ui-tars-smoke/.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_socketrGs+*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_addressr1 local_portr( raw_socketremote_address remote_portr)N)__name__ __module__r9__firstlineno____doc__rr;__annotations__rJrKrLrMrN__static_attributes__r)r-r+rIrIcsX@,-FM-"1"3M<3%'J' / 1J 1#2#4NL4&(K(r-rIcL]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`ras7  ,,.4r-c<SP#r\)r]r^sr+r`ras 0@0@r-Nc<S#r\r))peernamesr+r`rasr-cF<SPP4^,#)rcr^sr+r`ras  ,,.q1r-c<S#r\r))rNsr+r`ras+r-)_core._socketsrZrIr;rJrLr]r:r3rMr r<r=rKrN)r_ attributesrdrgrNsf @@@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,rXs  ] r-c R#r\r)r^s&r+r]_SocketProvider._raw_sockets r-r)N) rOrPr9rQpropertyrmrr]rTr)r-r+rVrVs0 <  r-rVc0]tRt^tRt]RRl4tRtR#) SocketStreamzi Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c V^8dQhRRRR/#)r!r"r#r'rtr))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)rGr2 SOCK_STREAMrwrap_stream_socketclsr"rDs&& r+ from_socketSocketStream.from_sockets6 F,>,>RVW&(;;DAAAA9AAAr)NrOrPr9rQrR classmethodr}rTr)r-r+rtrts  B Br-rtcX]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 TrxN)rGr2ryAF_UNIXrwrap_unix_stream_socketr{s&& 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!msglenr1maxfdsr'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) rOrPr9rQrr}rrrrTr)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)rGr2ryrwrap_listener_socketr{s&& r+r}SocketListener.from_sockets5 F,>,>dS&(==dCCCCrcV^8dQhRR/#)r!r'rtr))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\) rOrPr9rQrRrr}rrrrTr)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)rGr2 SOCK_DGRAMrwrap_udp_socketr{s&& r+r}UDPSocket.from_socket#s5 F,=,=TR&(88>>>>rc(V^8dQhRRRRRRRR/#) r!datarhoststrportr1r'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 rOrPr9rQrRrr}rrTr)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 TrxN)rGr2rrwrap_connected_udp_socketr{s&& r+r}ConnectedUDPSocket.from_socketAs<    "  '(BB4HHHHrr)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)rGr2rrrwrap_unix_datagram_socketr{s&& 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 TrxN)rGr2rrr#wrap_connected_unix_datagram_socketr{s&& r+r}'ConnectedUNIXDatagramSocket.from_socket|s@  ))6>>T '(LLTRRRRrr)Nrr)r-r+rrus SSr-r)9__conditional_annotations__ __future__rr4r2abcrcollections.abcrrr contextlibrior ipaddressr r r typingr rr_core._eventloopr_core._typedattrrrr_streamsrrr_tasksrrrrStupler1rrrrrrr?rGrIrVrtrrrrrr)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-