Struct WebTransportSession

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

WebTransport session driver.

Maintains the session using the underlying HTTP/3 connection.

Similar to h3::server::Connection it is generic over the QUIC implementation and Buffer.

Implementations

impl<C, B> WebTransportSession<C, B>

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

pub fn session_id(&self) -> SessionId

Returns the session id

pub async fn accept_bi(&self) -> Option<BidiStream<C::BidiStream, B>>

Accepts a bidi stream

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

Polls for a bidi stream

pub async fn accept_uni(&self) -> Option<RecvStream<C::RecvStream, B>>

Accepts a uni stream

pub fn poll_accept_uni( &self, cx: &mut Context<'_>, ) -> Poll<Option<RecvStream<C::RecvStream, B>>>

Polls for a uni stream

pub async fn accept_datagram(&self) -> Option<B>

Accepts a datagram

pub fn poll_accept_datagram(&self, cx: &mut Context<'_>) -> Poll<Option<B>>

Polls for a datagram

pub async fn send_datagram(&self, datagram: B) -> Result<(), Error>

Sends a datagram

pub async fn open_bi( &self, ) -> Result<BidiStream<C::BidiStream, B>, <C::OpenStreams as OpenStreams<B>>::OpenError>

Opens a bidi stream

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

Polls to open a bidi stream

pub async fn open_uni( &self, ) -> Result<SendStream<C::SendStream, B>, <C::OpenStreams as OpenStreams<B>>::OpenError>

Opens a uni stream

pub fn poll_open_uni( &self, cx: &mut Context<'_>, ) -> Poll<Result<SendStream<C::SendStream, B>, <C::OpenStreams as OpenStreams<B>>::OpenError>>

Polls to open a uni stream

impl<C, B> WebTransportSession<C, B>

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

pub fn begin<B2, F, Fut>( request: &mut Request<B2>, on_upgrade: F, ) -> Option<Response<()>>

where C: Connection<B> + 'static, B: Buf + 'static + Send + Sync, C::AcceptError: Send + Sync, C::BidiStream: Send + Sync, C::RecvStream: Send + Sync, C::OpenStreams: Send + Sync, Fut: Future<Output = ()> + Send + Sync + 'static, F: FnOnce(WebTransportSession<C, B>) -> Fut + Send + Sync + 'static,

Begin a WebTransport session upgrade

pub fn complete( response: &mut Response<B>, stream: RequestStream<C::BidiStream, B>, ) -> Result<BoxFuture<'static, Result<(), Error>>, RequestStream<C::BidiStream, B>>

where C: Connection<B> + 'static, B: Buf + 'static + Send + Sync,

Completes the WebTransport upgrade

pub async fn accept<E, E2>( request: &mut Request<()>, stream: RequestStream<C::BidiStream, B>, ) -> Result<Option<WebTransportSession<C, B>>, Error>

where C: Connection<B> + SendDatagramExt<B, Error = E> + RecvDatagramExt<Buf = B, Error = E2> + 'static, B: Buf + 'static + Send + Sync, C::AcceptError: Send + Sync, C::BidiStream: Send + Sync, C::RecvStream: Send + Sync, C::OpenStreams: Send + Sync, E: Into<Error>, E2: Into<Error>,

Accepts a WebTransport session from an incoming request

Trait Implementations

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

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

fn drop(&mut self)

Executes the destructor for this type.