Struct Session 

pub struct Session<S: Session> { /* private fields */ }

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.

Implementations

impl<S: Session + Sync> Session<S>

pub async fn connect( session: S, publish: impl Into<Option<OriginConsumer>>, subscribe: impl Into<Option<OriginProducer>>, ) -> Result<Self, Error>

Perform the MoQ handshake as a client.

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

Perform the MoQ handshake as a server

pub fn close(self, err: Error)

Close the underlying transport session.

pub async fn closed(&self) -> Error

Block until the transport session is closed.