Struct Session 

pub struct Session(/* private fields */);

👎Deprecated:

use qmux::Session with qmux::ws::accept/connect instead

A WebTransport session over WebSocket.

Deprecated

Use qmux::Session with qmux::ws::accept / qmux::ws::connect instead.

Implementations

impl Session

pub fn accept<T>(ws: T, protocol: Option<String>) -> Self

where T: Stream<Item = Result<Message, Error>> + Sink<Message, Error = Error> + Unpin + Send + 'static,

Wrap a pre-upgraded WebSocket as a server-side session.

pub fn connect<T>(ws: T, protocol: Option<String>) -> Self

where T: Stream<Item = Result<Message, Error>> + Sink<Message, Error = Error> + Unpin + Send + 'static,

Wrap a pre-upgraded WebSocket as a client-side session.

pub fn into_inner(self) -> Session

Get the inner qmux::Session.

Trait Implementations

impl Clone for Session

fn clone(&self) -> Session

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl From<Session> for Session

fn from(s: Session) -> Self

Converts to this type from the input type.

impl From<Session> for Session

fn from(s: Session) -> Self

Converts to this type from the input type.

impl Session for Session

type SendStream = SendStream

type RecvStream = RecvStream

type Error = Error

async fn accept_uni(&self) -> Result<Self::RecvStream, Self::Error>

Block until the peer creates a new unidirectional stream.

async fn accept_bi( &self, ) -> Result<(Self::SendStream, Self::RecvStream), Self::Error>

Block until the peer creates a new bidirectional stream.

async fn open_uni(&self) -> Result<Self::SendStream, Self::Error>

Open a new unidirectional stream, which may block when there are too many concurrent streams.

async fn open_bi( &self, ) -> Result<(Self::SendStream, Self::RecvStream), Self::Error>

Open a new bidirectional stream, which may block when there are too many concurrent streams.

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

Close the connection immediately with a code and reason.

async fn closed(&self) -> Self::Error

Block until the connection is closed by either side.

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

Return the negotiated WebTransport subprotocol, if any.

fn send_datagram(&self, payload: Bytes) -> Result<(), Self::Error>

Send a datagram over the network.

async fn recv_datagram(&self) -> Result<Bytes, Self::Error>

Receive a datagram over the network.

fn max_datagram_size(&self) -> usize

The maximum size of a datagram that can be sent.

fn stats(&self) -> impl Stats

Return connection-level statistics, if supported.