+ P\i3csa0t$^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?III3I9cs]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 r1r local_addressr+ local_portr$ raw_socketremote_address remote_portr%N)__name__ __module__r/__firstlineno____doc__rr1__annotations__r9r:r;r<r=__static_attributes__r%r*r(r8r8isX@,-FM-"1"3M<3%'J' / 1J 1#2#4NL4&(K(r*r8csL]tRt^t]RRl4t]]RRl44tRtR#)_SocketProvidercV^8dQhRR/#)rr#zMapping[Any, Callable[[], Any]]r%r&r'r(r)_SocketProvider.__annotate__s"Ar*c saaaa^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_sockaddrcs0<SPP#N) _raw_socketr1selfr(2_SocketProvider.extra_attributes..sD,<,<,C,Cr*csD<S!SPP44#rHrIr4)convertrKsr(rMrNs7  ,,.4r*cs<SP#rH)rIrJrLr(rMrNs 0@0@r*Nc<S#rHr%)peernamerLr(rMrNsr*csF<SPP4^,#)irOrJrLr(rMrNs((446q9r*crQrHr%)r=rLr(rMrNs+r*)Z_core._socketsrGr8r1r9r;rIr0r-r<r r2r3r:r=)rKZ attributesrPrRr=sf @@@r(extra_attributesZ _SocketProvider.extra_attributessE  " "$C  ) ),  & &(@ 4  /6t7G7G7S7S7U/VH  9IJ55 6    " "}'<'T>T&U U9 11 2#&qk :M ?667! H s C<< D  D crE)rr#r$r%r&r'r(r)rFs  ] r*c sR#rHr%rJ&r(rIZ_SocketProvider._raw_sockets r*r%N) r>r?r/r@ZpropertyrSrrIrCr%r*r(rDrDs0 <  r*rDcs0]tRt^tRt]RRl4tRtR#) SocketStreamzi Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c V^8dQhRRRR/#)rrr r#rUr%r&r'r(r)ZSocketStream.__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)r7r, SOCK_STREAMr Zwrap_stream_socketZclsrr6&& r( from_socketZSocketStream.from_sockets6 F,>,>RVW&(;;DAAAA9AAAr%Nr>r?r/r@rA classmethodr\rCr%r*r(rUrUs  B Br*rUcsX]tRt^t]RRl4t]RRl4t]RRl4tRt R#) UNIXSocketStreamcrV)rrr r#r`r%r&r'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)r7r,rYAF_UNIXr Zwrap_unix_stream_socketrZr[r(r\ZUNIXSocketStream.from_sockets@ **FNNd '(@@FFFFAA A Ac$V^8dQhRRRRRR/#)rmessagebytesfdszCollection[int | IOBase]r#Noner%r&r'r(r)ras"  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%)rKrfrh&&&r(send_fdsZUNIXSocketStream.send_fdscs$V^8dQhRRRRRR/#)rmsglenr+maxfdsr#ztuple[bytes, list[int]]r%r&r'r(r)ras"   S =T r*c rj)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%)rKrorprkr( receive_fdsZUNIXSocketStream.receive_fdsrmrnr%N) r>r?r/r@r_r\rrlrqrCr%r*r(r`r`s>GG     r*r`csV]tRt^tRt]RRl4t]RRl4tR RRllt R t R#) SocketListenerzq Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. crV)rrr r#rrr%r&r'r(r)SocketListener.__annotate__s"DD'D Dr*c rW)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)r7r,rYr Zwrap_listener_socketrZr[r(r\ZSocketListener.from_sockets5 F,>,>dS&(==dCCCCr]crE)rr#rUr%r&r'r(r)rss--l-r*c rj)zAccept an incoming connection.Nr%rJrTr(acceptZSocketListener.acceptrmrnNcre)rhandlerzCallable[[SocketStream], Any] task_groupzTaskGroup | Noner#rir%r&r'r(r)rss( 7 7. 7% 7  7r*c s."^RIHp\4;_uu_4GRjxL pVfVPV!44GRjxL pVP 4GRjxL pVP W4K,LRL2L +GRjxL 'giR#;i5i)r)create_task_groupN)ZrxrZenter_async_contextruZ start_soon)rKrvrwrxZstackZstreams&&& r(serveZSocketListener.serveso )!###u!#(#<#<=N=P#QQ #{{},%%g6 $Q- $###s\BA2BA8A4A8A6A82B4A86A88B >B? B B Br%rH) r>r?r/r@rAr_r\rruryrCr%r*r(rrrrs; DD -- 7 7r*rrc<]tRtRtRt]RRl4tRRltRtR#) UDPSocketi"zo Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. crV)rrr r#r{r%r&r'r(r)UDPSocket.__annotate__*s ? ?+> ?9 ?r*c rW)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 TrtN)r7r, SOCK_DGRAMr Zwrap_udp_socketrZr[r(r\ZUDPSocket.from_socket)s5 F,=,=TR&(88>>>>r]cs(V^8dQhRRRRRRRR/#) rdatarghoststrportr+r#rir%r&r'r(r)r|8s(555c555r*c sF"VPWV334GRjxL #L5i)zN Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). NZsend)rKr~rrs&&&&r(sendtoZUDPSocket.sendto8s# YYTl34444s !!r%N r>r?r/r@rAr_r\rrCr%r*r(r{r{"s%  ? ?55r*r{c0]tRtRtRt]RRl4tRtR#)ConnectedUDPSocketi@zm Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. crV)rrr r#rr%r&r'r(r)ZConnectedUDPSocket.__annotate__Hs II+>ICUIr*c rW)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)r7r,r}r Zwrap_connected_udp_socketrZr[r(r\ZConnectedUDPSocket.from_socketGs<    "  '(BB4HHHHr]r%Nr^r%r*r(rr@s IIr*rcrz) UNIXDatagramSocketi[zy Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. crV)rrr r#rr%r&r'r(r)UNIXDatagramSocket.__annotate__es"II'I Ir*c s"\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)r7r,r}rcr Zwrap_unix_datagram_socketrZr[r(r\ZUNIXDatagramSocket.from_socketds9 F,=,=v~~N&(BB4HHHHsAAA  Acre)rr~rgpathrr#rir%r&r'r(r)rvs!---c-d-r*c sB"VPW34GRjxL #L5i)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)rKr~rrkr(rZUNIXDatagramSocket.sendtovsYY|,,,,s r%Nrr%r*r(rr[s' II"--r*rcr)ConnectedUNIXDatagramSocketi{zv Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. crV)rrr r#rr%r&r'r(r)Z(ConnectedUNIXDatagramSocket.__annotate__s"SS'S %Sr*c rb)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)r7r,r}rcr Z#wrap_connected_unix_datagram_socketrZr[r(r\Z'ConnectedUNIXDatagramSocket.from_sockets@  ))6>>T '(LLTRRRRrdr%Nr^r%r*r(rr{s SSr*r)ii )=__conditional_annotations__Z __future__rr.r,ZsysZabcrZcollections.abcrrrZ contextlibrZiorZ ipaddressrrr Ztypingr r r Z_core._eventloopr Z_core._typedattrrrrZ_streamsrrrZ_tasksrZ version_inforZtyping_extensionsrrrBZtupler+rrrgrrrr5r7r8rDrUr`rrr{rrr)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*