mbi:ddlmZddlZddlZddlZddlmZddlmZm Z m Z ddl m Z ddl mZddlmZd d lmZmZd gZeed sd e_ededddddd"d!ZdS)#) annotationsN)asynccontextmanager)AsyncGeneratorCallablecast)QuicConfiguration)QuicConnection)SessionTicketHandler)QuicConnectionProtocolQuicStreamHandlerconnect IPPROTO_IPV6)T) configurationcreate_protocolsession_ticket_handlerstream_handlerwait_connected local_porthoststrportintrQuicConfiguration | NonerCallable | NonerSessionTicketHandler | NonerQuicStreamHandler | Nonerboolrreturn&AsyncGenerator[QuicConnectionProtocol]cKtj}d} tj|d} n#t$r|} YnwxYw|||t jd{V} | dd} t| dkrd| dz| dddf} |td }|j | |_ t|| t jt j t j} d } | t jt jd| | |ddfd }|s| n#|s| wwxYw|fd | d{V\}}t't(|} || |r|d{V|WV||d{V|dS#||d{V|wxYw)aa Connect to a QUIC server at the given `host` and `port`. :meth:`connect()` returns an awaitable. Awaiting it yields a :class:`~qh3.asyncio.QuicConnectionProtocol` which can be used to create streams. :func:`connect` also accepts the following optional arguments: * ``configuration`` is a :class:`~qh3.quic.configuration.QuicConfiguration` configuration object. * ``create_protocol`` allows customizing the :class:`~asyncio.Protocol` that manages the connection. It should be a callable or class accepting the same arguments as :class:`~qh3.asyncio.QuicConnectionProtocol` and returning an instance of :class:`~qh3.asyncio.QuicConnectionProtocol` or a subclass. * ``session_ticket_handler`` is a callback which is invoked by the TLS engine when a new session ticket is received. * ``stream_handler`` is a callback which is invoked whenever a stream is created. It must accept two arguments: a :class:`asyncio.StreamReader` and a :class:`asyncio.StreamWriter`. * ``local_port`` is the UDP port number that this client wants to bind. z::N)typerrz::ffff:r T) is_client)rrFcS)N)r) connectionrrsb/var/www/html/mdtn/previsions/meteo_cartes/venv/lib/python3.11/site-packages/qh3/asyncio/client.pyzconnect..\s >JJJ)sock)asyncioget_running_loop ipaddress ip_address ValueError getaddrinfosocket SOCK_DGRAMlenr server_namer AF_INET6 setsockoptr IPV6_V6ONLYbindclosecreate_datagram_endpointrr rr wait_closed)rrrrrrrrloop local_hostr7infosaddrr- completed transportprotocolr)s ` ` @r*rrsD  # % %DJT"""  ""4F4E"FF F F F F F FE 8A;D 4yyA~~DG#T!Wa3)D999  ($/ !#!!Ix*H55H  ,))++ + + + + + + +""$$$$$$$$$ ""$$$$$$$$$s)3 AAAEE646H..AI2)rrrrrrrrrrrrrr rrr!r") __future__rr.r0r4 contextlibrtypingrrrquic.configurationr quic.connectionr tlsr rEr r__all__hasattrrrr(r,r*rNs)"""""" ******1111111111222222,,,,,,&&&&&&???????? +wv~&&F /3'=:>/3RRRRRRRRr,