Struct Request 

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

A paused server-side handshake.

Returned by Server::accept_request once the peer’s advertised path is known but before the session is granted anything. Set the origins to serve, then call ok to complete the handshake, or close to reject it. Modeled on the WebTransport Request in moq-native.

Implementations

impl<S: Session> Request<S>

pub fn path(&self) -> &str

The request path the client advertised in its SETUP.

Empty when the client advertised none: either it sent an empty path, or the version carries none in-band (lite 01-04). Those mean the same thing, so the wire distinction isn’t surfaced. Populated for moq-lite-05 and every moq-transport draft we speak. See the note on Server::accept_request.

pub fn role(&self) -> Option<Role>

The single Role the client advertised in its SETUP, or None for a bidirectional session.

Only moq-lite-05 carries a role, so None covers three cases that the wire doesn’t distinguish: an older version, a client that omitted the parameter, and a client that explicitly advertised both directions. All three mean the same thing (the client may publish and subscribe), so authorize on what the token grants. See the note on Server::accept_request.

pub fn with_publisher(self, publish: impl Consume<Consumer>) -> Self

Publish to the connected client. Overrides any value from the Server builder; typically set after inspecting path.

pub fn with_subscriber(self, subscribe: Producer) -> Self

Subscribe to the connected client. Overrides any value from the Server builder.

pub fn with_stats(self, stats: Session) -> Self

Set the per-connection stats::Session context. Overrides any value from the Server builder.

pub async fn ok(self) -> Result<(Session, Driver), Error>

Accept the session, returning the Session and the Driver that runs its protocol work.

pub fn close(self, err: Error)

Reject the session, closing the transport with err’s wire code.

Trait Implementations

impl<S: Session> Drop for Request<S>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.