+ Di3a0t$^RIHt^RIt^RIt^RIt^RIHt^RIH t H t H t ^RI H t ^RIHt^RIHtHt^RIHt^R IHtHtHt^R IHt^R IHtHtHt^R IHtH t H!t!^R I"H#t#]PHR-8d^RIH%t%M^RI&H%t%]]']]3,t(R])R&]*]']+3,t,R])R&]],]'3,t-R])R&]*].],3,t/R])R&]*].]'3,t0R])R&]!R4t1]Pd3RRRR/RRlllt3!RR]4t4!RR]4t5!RR ]]54t6!R!R"]64t7!R#R$] ]6,]54t8!R%R&]!]/,]54t9!R'R(]!].,]54t:!R)R*]!]0,]54t;!R+R,]!].,]54t.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^it$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_addressr2 local_portr) raw_socketremote_address remote_portr*N)__name__ __module__r:__firstlineno____doc__rr<__annotations__rKrLrMrNrO__static_attributes__r*r.r,rJrJisX@,-FM-"1"3M<3%'J' / 1J 1#2#4NL4&(K(r.rJcL]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,rarbs7  ,,.4r.c<SP#r])r^r_sr,rarbs 0@0@r.Nc<S#r]r*)peernamesr,rarbsr.cF<SPP4^,#)rdr_sr,rarbs((446q9r.c<S#r]r*)rOsr,rarbs+r.)_core._socketsr[rJr<rKrMr^r;r4rNr r=r>rLrO)r` attributesrerhrOsf @@@r,extra_attributes _SocketProvider.extra_attributessE  " "$C  ) ),  & &(@ 4  /6t7G7G7S7S7U/VH  9IJ55 6    " "}'<'T>T&U U9 11 2#&qk :M ?667! H s C<< D  D cV^8dQhRR/#)r"r(r)r*)r+s"r,r-rYs  ] r.c R#r]r*r_s&r,r^_SocketProvider._raw_sockets r.r*N) rPrQr:rRpropertyrnrr^rUr*r.r,rWrWs0 <  r.rWc0]tRt^tRt]RRl4tRtR#) SocketStreamzi Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c V^8dQhRRRR/#)r"r#r$r(rur*)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)rHr3 SOCK_STREAMrwrap_stream_socketclsr#rEs&& r, from_socketSocketStream.from_sockets6 F,>,>RVW&(;;DAAAA9AAAr*NrPrQr:rRrS classmethodr~rUr*r.r,rurus  B Br.rucX]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 TryN)rHr3rzAF_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"msglenr2maxfdsr(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) rPrQr:rRrr~rrrrUr*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 Tr N)rHr3rzrwrap_listener_socketr|s&& r,r~SocketListener.from_sockets5 F,>,>dS&(==dCCCCrcV^8dQhRR/#)r"r(rur*)r+s"r,r-rs--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-rs( 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.serveso )!###u!#(#<#<=N=P#QQ #{{},%%g6 $Q- $###s\BA2BA8A4A8A6A82B4A86A88B >B? B B Br*r]) rPrQr:rRrSrr~rrrrUr*r.r,rrs; DD -- 7 7r.rc<]tRtRtRt]RRl4tRRltRtR#) UDPSocketi"zo 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)rHr3 SOCK_DGRAMrwrap_udp_socketr|s&& r,r~UDPSocket.from_socket)s5 F,=,=TR&(88>>>>rc(V^8dQhRRRRRRRR/#) r"datarhoststrportr2r(rr*)r+s"r,r-r8s(555c555r.c F"VPWV334GRjxL #L5i)zN Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)r`rrrs&&&&r,sendtoUDPSocket.sendto8s# YYTl34444s !!r*N rPrQr:rRrSrr~rrUr*r.r,rr"s%  ? ?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__Hs 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 TryN)rHr3rrwrap_connected_udp_socketr|s&& r,r~ConnectedUDPSocket.from_socketGs<    "  '(BB4HHHHrr*Nrr*r.r,rr@s IIr.rc<]tRtRtRt]RRl4tRRltRtR#) UNIXDatagramSocketi[zy 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__es"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)rHr3rrrwrap_unix_datagram_socketr|s&& r,r~UNIXDatagramSocket.from_socketds9 F,=,=v~~N&(BB4HHHHsAAA  Ac$V^8dQhRRRRRR/#)r"rrpathrr(rr*)r+s"r,r-rvs!---c-d-r.c B"VPW34GRjxL #L5i)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)r`rrs&&&r,rUNIXDatagramSocket.sendtovsYY|,,,,s r*Nrr*r.r,rr[s' II"--r.rc0]tRtRtRt]RRl4tRtR#)ConnectedUNIXDatagramSocketi{zv 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 TryN)rHr3rrr#wrap_connected_unix_datagram_socketr|s&& r,r~'ConnectedUNIXDatagramSocket.from_sockets@  ))6>>T '(LLTRRRRrr*Nrr*r.r,rr{s SSr.r) )=__conditional_annotations__ __future__rr5r3sysabcrcollections.abcrrr contextlibrior ipaddressr r r typingr rr_core._eventloopr_core._typedattrrrr_streamsrrr_tasksr version_infortyping_extensionsrrrTtupler2rrrrrrr@rHrJrWrurrrrrr)rs@r,rs"" 99%. &&0 CBw + k;!>? y?!#s(O + 34 i4 !67 y7$)%*$5 5 :  )/(8(8B $ B  BBJ&)'&)R# ,# LB:B.$ |$ N)7Xl+_)7X5&}55<I/6I6-12O-@S"8"?Sr.