Struct Ctx 

pub struct Ctx<'a, Svc: ?Sized, St = ()> { /* private fields */ }

Implementations

impl<'a, Svc, St> Ctx<'a, Svc, St>

pub fn id(&self) -> u32

Unique id for this pipeline

pub fn st(&'a self) -> &'a St

Service state

pub async fn ready<S, Req>(&self, svc: &'a S) -> Result<(), S::Error>

where S: Service<St, Req>,

Returns when the service is able to process requests.

pub async fn call<S, Req>( &self, svc: &'a S, req: Req, ) -> Result<S::Res, S::Error>

where S: Service<St, Req>,

Wait for service readiness and then call service

pub async fn call_nowait<S, Req>( &self, svc: &'a S, req: Req, ) -> Result<S::Res, S::Error>

where S: Service<St, Req>,

Call service, do not check service readiness

pub async fn poll_fn<F, R>(&'a self, f: F) -> R

where F: Fn(&mut Context<'a>) -> Poll<R>,

Execute a closure until completion with the dispatcher’s task Context.

pub fn poll_once<F, R>(&'a self, f: F) -> R

where F: FnOnce(&mut Context<'a>) -> R,

Execute a closure with the dispatcher’s task Context.

pub async fn shutdown<S, Req>(&self, svc: &'a S)

where S: Service<St, Req>,

Shutdown service

pub fn map_state<NewSt>(&'a self, st: &'a NewSt) -> Ctx<'a, Self, NewSt>

Map context state

Trait Implementations

impl<S, St> Clone for Ctx<'_, S, St>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S, St> Copy for Ctx<'_, S, St>

impl<S, St> Debug for Ctx<'_, S, St>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<S, St> Deref for Ctx<'_, S, St>

type Target = St

The resulting type after dereferencing.

fn deref(&self) -> &St

Dereferences the value.