Struct Session

pub struct Session {
    pub webtransport: Session,
}

A MoQ session, constructed with [Publisher] and [Subscriber] halves.

This simplifies the state machine and immediately rejects any subscriptions that don’t match the origin prefix. You probably want to use Session unless you’re writing a relay.

Fields

webtransport: Session

Implementations

impl Session

pub async fn connect<T: Into<Session>, P: Into<Option<OriginConsumer>>, C: Into<Option<OriginProducer>>>( session: T, publish: P, subscribe: C, ) -> Result<Self, Error>

Perform the MoQ handshake as a client.

pub async fn accept<T: Into<Session>, P: Into<Option<OriginConsumer>>, C: Into<Option<OriginProducer>>>( session: T, publish: P, subscribe: C, ) -> Result<Self, Error>

Perform the MoQ handshake as a server

pub fn close(self, err: Error)

Close the underlying WebTransport session.

pub async fn closed(&self) -> Error

Block until the WebTransport session is closed.

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.