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<Self, Error>

Create a new HTTP/3 server connection with default settings

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

pub fn close<T: AsRef<str>>(&mut self, code: Code, reason: T) -> Error

Closes the connection with a code and a reason.

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

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

pub async fn accept( &mut self, ) -> Result<Option<(Request<()>, RequestStream<C::BidiStream, B>)>, Error>

Accept an incoming request.

It returns a tuple with a http::Request and an RequestStream. The http::Request is the received request from the client. The RequestStream can be used to send the response.

pub fn accept_with_frame( &mut self, stream: FrameStream<C::BidiStream, B>, frame: Result<Option<Frame<PayloadLen>>, FrameStreamError>, ) -> Result<Option<ResolveRequest<C, B>>, Error>

Accepts an http request where the first frame has already been read and decoded.

This is needed as a bidirectional stream may be read as part of incoming webtransport bi-streams. If it turns out that the stream is not a WEBTRANSPORT_STREAM the request may still want to be handled and passed to the user.

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

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

See connection shutdown for more information.

pub fn poll_accept_request( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<Option<C::BidiStream>, Error>>

Accepts an incoming bidirectional stream.

This could be either a Request or a WebTransportBiStream, the first frame’s type decides.

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

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

pub fn send_datagram( &mut self, stream_id: StreamId, data: B, ) -> Result<(), Error>

Sends a datagram

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

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

pub fn read_datagram(&mut self) -> ReadDatagram<'_, C, B>

Reads an incoming datagram

Trait Implementations

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

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

fn drop(&mut self)

Executes the destructor for this type.