Struct Http3 

pub struct Http3<Io> { /* private fields */ }

Available on crate feature h3 only.

An HTTP/3 connection handler.

Http3 wraps a QUIC connection (Io) and drives the HTTP/3 server connection over the native transport stack. It supports:

• Concurrent request stream handling
• Streaming request/response bodies and trailers
• Automatic 100 Continue and 103 Early Hints interim responses
• Per-connection Date header caching
• Graceful shutdown via a CancellationToken

Construction

let http3 = Http3::new(quic_connection, Http3Options::default());

Serving requests

Use the HttpProtocol trait methods (handle / handle_with_error_fn) to drive the connection to completion.

Implementations

impl<Io> Http3<Io>

where Io: Connection + Unpin + 'static,

pub fn new(io: Io, options: Http3Options) -> Self

Creates a new Http3 connection handler wrapping the given QUIC connection.

The options value controls HTTP/3 protocol configuration, connection setup and accept timeouts, and optional behaviour such as automatic 100 Continue responses; see Http3Options for details.

Example

let http3 = Http3::new(quic_connection, Http3Options::default());

pub fn graceful_shutdown_token(self, token: CancellationToken) -> Self

Attaches a CancellationToken for graceful shutdown.

When the token is cancelled, the handler sends an HTTP/3 graceful shutdown signal (GOAWAY), stops accepting new request streams, and exits cleanly once the in-flight requests have drained.

Trait Implementations

impl<Io> HttpProtocol for Http3<Io>

where Io: Connection + Unpin + 'static,

fn handle<F, Fut, ResB, ResBE, ResE>( self, request_fn: F, ) -> impl Future<Output = Result<(), Error>>

where F: Fn(Request<Incoming>) -> Fut + 'static, Fut: Future<Output = Result<Response<ResB>, ResE>> + 'static, ResB: Body<Data = Bytes, Error = ResBE> + Unpin + 'static, ResE: Error + 'static, ResBE: Error + 'static,

fn handle_with_error_fn<F, Fut, ResB, ResBE, ResE, EF, EFut, EResB, EResBE, EResE>( self, request_fn: F, error_fn: EF, ) -> impl Future<Output = Result<(), Error>>

where F: Fn(Request<Incoming>) -> Fut + 'static, Fut: Future<Output = Result<Response<ResB>, ResE>> + 'static, ResB: Body<Data = Bytes, Error = ResBE> + Unpin + 'static, ResE: Error + 'static, ResBE: Error + 'static, EF: FnOnce(bool) -> EFut, EFut: Future<Output = Result<Response<EResB>, EResE>>, EResB: Body<Data = Bytes, Error = EResBE> + Unpin + 'static, EResE: Error + 'static, EResBE: Error + 'static,