Struct 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 pipeline is able to process requests.

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, 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, R: 'static,

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

Note, this call does not check service readiness.

pub fn is_shutdown(&self) -> bool

Check if shutdown is initiated.

pub async fn shutdown<R>(&self)

where S: Service<R>,

Shutdown enclosed service.

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

where S: Service<R>,

pub fn bind<R>(self) -> PipelineBinding<S, R>

where S: Service<R> + 'static, R: 'static,

Get current pipeline.

Trait Implementations

impl<S> Clone for Pipeline<S>

fn clone(&self) -> Self

Returns a duplicate 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> Drop for Pipeline<S>

fn drop(&mut self)

Executes the destructor for this type.

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

fn from(svc: S) -> Self

Converts to this type from the input type.