Struct RequestCtx 

pub struct RequestCtx { /* private fields */ }

Per-request context. Retains the full route handle and correlation id, provides interim stream emission, and exposes a cancellation signal.

Implementations

impl RequestCtx

pub fn route_handle(&self) -> RouteHandle

Full route handle retained from ingress.

pub fn corr(&self) -> u64

Correlation id for this request.

pub async fn emit(&self, body: Vec<u8>) -> Result<(), SubcModuleError>

Emit an interim StreamData frame on this request’s (channel, corr). Once the request is cancelled or its route is gone, late emits are dropped.

pub async fn emit_with_admission( &self, body: Vec<u8>, admission_class: Option<AdmissionClass>, ) -> Result<(), SubcModuleError>

Emit StreamData with an explicit admission class. None means NORMAL.

pub fn cancelled(&self) -> WaitForCancellationFuture<'_>

Completes when the other side sends Cancel for this request or the route is torn down.

pub fn cancellation_token(&self) -> CancellationToken

Return a cloneable cancellation token for code that prefers token polling.

Trait Implementations

impl Clone for RequestCtx

fn clone(&self) -> RequestCtx

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.