Struct Connection 

pub struct Connection<C, B>
where
    C: Connection<B>,
    B: Buf,
{
    pub inner: ConnectionInner<C, B>,
    /* private fields */
}

Server connection driver

The Connection struct manages a connection from the side of the HTTP/3 server

Create a new Instance with Connection::new(). Accept incoming requests with Connection::accept(). And shutdown a connection with Connection::shutdown().

Fields

inner: ConnectionInner<C, B>

TODO: temporarily break encapsulation for WebTransportSession

Implementations

impl<C, B> Connection<C, B>

where C: Connection<B>, B: Buf,

pub async fn new(conn: C) -> Result<Connection<C, B>, ConnectionError>

Create a new HTTP/3 server connection with default settings

Use a custom super::builder::Builder with super::builder::builder() to create a connection with different settings. Provide a Connection which implements quic::Connection.

impl<C, B> Connection<C, B>

where C: Connection<B>, B: Buf,

Impls for extension implementation which are not stable

pub fn create_resolver( &self, stream: FrameStream<<C as OpenStreams<B>>::BidiStream, B>, ) -> RequestResolver<C, B>

Create a RequestResolver to handle an incoming request.

pub fn poll_accept_request_stream( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<Option<<C as OpenStreams<B>>::BidiStream>, ConnectionError>>

Polls the Connection and accepts an incoming request_streams

impl<C, B> Connection<C, B>

where C: Connection<B>, B: Buf,

pub async fn accept( &mut self, ) -> Result<Option<RequestResolver<C, B>>, ConnectionError>

Accept an incoming request.

This method returns a RequestResolver which can be used to read the request and send the response. This method will return None when the connection receives a GOAWAY frame and all requests have been completed.

pub async fn shutdown( &mut self, max_requests: usize, ) -> Result<(), ConnectionError>

Initiate a graceful shutdown, accepting max_request potentially still in-flight

See connection shutdown for more information.

Trait Implementations

impl<C, B> ConnectionState for Connection<C, B>

where C: Connection<B>, B: Buf,

fn shared_state(&self) -> &SharedState

Get the shared state

fn get_conn_error(&self) -> Option<ErrorOrigin>

Get the connection error if the connection is in error state because of another task

fn set_conn_error(&self, error: ErrorOrigin) -> ErrorOrigin

tries to set the connection error

fn set_conn_error_and_wake<T>(&self, error: T) -> ErrorOrigin

where T: Into<ErrorOrigin>,

set the connection error and wake the connection

fn settings(&self) -> Cow<'_, Settings>

Get the settings

fn set_closing(&self)

Set the connection to closing

fn is_closing(&self) -> bool

Check if the connection is closing

fn set_settings(&self, settings: Settings)

Set the settings

fn waker(&self) -> &AtomicWaker

Returns the waker for the connection

impl<C, B> Drop for Connection<C, B>

where C: Connection<B>, B: Buf,

fn drop(&mut self)

Executes the destructor for this type.

impl<B, C> HandleDatagramsExt<C, B> for Connection<C, B>

where B: Buf, C: Connection<B> + DatagramConnectionExt<B>,

fn get_datagram_sender( &self, stream_id: StreamId, ) -> DatagramSender<<C as DatagramConnectionExt<B>>::SendDatagramHandler, B>

Get the datagram sender

fn get_datagram_reader( &self, ) -> DatagramReader<<C as DatagramConnectionExt<B>>::RecvDatagramHandler>

Get the datagram reader