Struct Session

pub struct Session {
    pub webtransport: Session,
}

A MoQ session, constructed with OriginProducer and OriginConsumer 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( session: impl Into<Session>, publish: impl Into<Option<OriginConsumer>>, subscribe: impl Into<Option<OriginProducer>>, ) -> 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.