Struct ntex_service::Pipeline

pub struct Pipeline<S> { /* private fields */ }

Container for a service.

Container allows to call enclosed service and adds support of shared readiness.

Implementations

impl<S> Pipeline<S>

pub fn new(svc: S) -> Self

Construct new container instance.

pub fn get_ref(&self) -> &S

Return reference to enclosed service

pub async fn ready<R>(&self) -> Result<(), S::Error>

where S: Service<R>,

Returns when the service is able to process requests.

pub fn poll_ready<R>(&self, cx: &mut Context<'_>) -> Poll<Result<(), S::Error>>

where S: Service<R>,

Returns Ready when the service is able to process requests.

pub fn poll_shutdown<R>(&self, cx: &mut Context<'_>) -> Poll<()>

where S: Service<R>,

Shutdown enclosed service.

pub async fn call<R>(&self, req: R) -> Result<S::Response, S::Error>

where S: Service<R>,

Wait for service readiness and then create future object that resolves to service result.

pub fn call_static<R>(&self, req: R) -> PipelineCall<S, R>

where S: Service<R> + 'static,

Wait for service readiness and then create future object that resolves to service result.

pub fn call_nowait<R>(&self, req: R) -> PipelineCall<S, R>

where S: Service<R> + 'static,

Call service and create future object that resolves to service result.

Note, this call does not check service readiness.

pub fn into_service(self) -> Option<S>

Extract service if container hadnt been cloned before.

Trait Implementations

impl<S> Clone for Pipeline<S>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S: Debug> Debug for Pipeline<S>

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

Formats the value using the given formatter.

impl<S> From<S> for Pipeline<S>

fn from(svc: S) -> Self

Converts to this type from the input type.