Struct salvo_core::webtransport::server::WebTransportSession

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

Available on crate feature quinn only.

A WebTransport session.

Implementations

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

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

pub fn split( self ) -> (Mutex<Connection<C, B>>, RequestStream<<C as Connection<B>>::BidiStream, B>)

Split the session into the underlying connection and stream.

pub async fn accept( stream: RequestStream<<C as Connection<B>>::BidiStream, B>, conn: Connection<C, B> ) -> Result<WebTransportSession<C, B>, Error>

Accepts a CONNECT request for establishing a WebTransport session.

TODO: is the API or the user responsible for validating the CONNECT request?

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

Receive a datagram from the client

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

where C: SendDatagramExt<B>,

Sends a datagram

TODO: maybe make async. quinn does not require an async send

pub fn accept_uni(&self) -> AcceptUni<'_, C, B>

Accept an incoming unidirectional stream from the client, it reads the stream until EOF.

pub async fn accept_bi(&self) -> Result<Option<AcceptedBi<C, B>>, Error>

Accepts an incoming bidirectional stream or request

pub fn open_bi(&self, session_id: SessionId) -> OpenBi<'_, C, B>

Open a new bidirectional stream

pub fn open_uni(&self, session_id: SessionId) -> OpenUni<'_, C, B>

Open a new unidirectional stream

pub fn session_id(&self) -> SessionId

Returns the session id