Struct SessionRequestOrder 

pub struct SessionRequestOrder { /* private fields */ }

One supervisor drains accepted requests even when its bridge disconnects. Each primary/reviewer stream runs in order, independently of other streams. Dropping the bridge closes admission but leaves its supervisor draining: disconnecting a caller cannot cancel a mutation that may already be accepted. Owners that can await shutdown use drain to observe that completion.

Implementations

impl SessionRequestOrder

pub fn new() -> Self

pub fn dispatch<F, Fut>(&mut self, request: RemoteSessionRequest, forward: F)

where F: FnOnce(RemoteSessionRequest) -> Fut + Send + 'static, Fut: Future<Output = ()> + Send + 'static,

Overload is an explicit non-admission, never ambiguous delivery.

pub async fn drain(self) -> Result<()>

Close admission and wait for all admitted work, including queued work.

Trait Implementations

impl Default for SessionRequestOrder

fn default() -> Self

Returns the “default value” for a type.