Struct PipelineBinding

pub struct PipelineBinding<S, R>
where
    S: Service<R>,
{ /* private fields */ }

Bound container for a service.

Implementations

impl<S, R> PipelineBinding<S, R>

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

pub fn get_ref(&self) -> &S

Return reference to enclosed service

pub fn pipeline(&self) -> Pipeline<S>

Get pipeline

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

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

Returns Ready when the pipeline is able to process requests.

panics if .poll_shutdown() was called before.

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

Returns Ready when the service is properly shutdowns.

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

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

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

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(&self)

Shutdown enclosed service.

Trait Implementations

impl<S, R> Clone for PipelineBinding<S, R>

where S: Service<R>,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S, R> Debug for PipelineBinding<S, R>

where S: Service<R> + Debug,

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

Formats the value using the given formatter.

impl<S, R> Drop for PipelineBinding<S, R>

where S: Service<R>,

fn drop(&mut self)

Executes the destructor for this type.