Struct Session 

pub struct Session { /* private fields */ }

A MoQ transport over the worker: raw QUIC, or a WebTransport session.

Request::respond builds the web flavor; Session::raw wraps a raw-QUIC Connection with the layering disabled. Clones share the session.

Implementations

impl Session

pub fn raw(conn: Connection) -> Self

Wrap a raw-QUIC connection in a session, with no WebTransport layering: streams and datagrams pass through untouched.

Trait Implementations

impl Clone for Session

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Session

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Session for Session

type SendStream = SendStream

The outgoing stream type. Only the poll half is required, so a !Send session can hang !Send streams off it.

type RecvStream = RecvStream

The incoming stream type. Only the poll half is required, so a !Send session can hang !Send streams off it.

type Error = Error

The error type for every operation on this session.

fn poll_accept_uni( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<Self::RecvStream, Self::Error>>

Poll for a unidirectional stream created by the peer.

fn poll_accept_bi( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<(Self::SendStream, Self::RecvStream), Self::Error>>

Poll for a bidirectional stream created by the peer.

fn poll_open_uni( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<Self::SendStream, Self::Error>>

Poll to open a unidirectional stream, which blocks while there are too many concurrent streams.

fn poll_open_bi( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<(Self::SendStream, Self::RecvStream), Self::Error>>

Poll to open a bidirectional stream, which blocks while there are too many concurrent streams.

fn poll_send_datagram( &mut self, cx: &mut Context<'_>, payload: &[u8], ) -> Poll<Result<(), Self::Error>>

Poll to send a datagram over the network.

fn poll_recv_datagram( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<Bytes, Self::Error>>

Poll for a datagram from the network.

fn max_datagram_size(&self) -> usize

The maximum size of a datagram that can be sent.

fn protocol(&self) -> Option<&str>

Return the application protocol negotiated for this session, if any.

fn close(&mut self, code: u32, reason: &str)

Close the connection immediately with a code and reason.

fn poll_closed(&mut self, cx: &mut Context<'_>) -> Poll<Self::Error>

Poll until the connection is closed by either side.

fn stats(&self) -> impl Stats

Return connection-level statistics.