Struct PipelineBinding 

pub struct PipelineBinding<Req, Res, Err> { /* private fields */ }

An independently registered handle to a Pipeline.

Bindings share the pipeline and its readiness state. Cloning a binding registers another handle.

Implementations

impl<Req, Res, Err> PipelineBinding<Req, Res, Err>

where Req: 'static, Res: 'static, Err: 'static,

pub async fn ready(&self) -> Result<(), Err>

Waits until the pipeline is ready to process a request.

A successful check is consumed by the next call, which then skips its own readiness check.

pub async fn call(&self, req: Req) -> Result<Res, Err>

Waits for readiness, then calls the service.

The readiness check is skipped if the last pipeline readiness check succeeded and no call has started since.

pub fn call_static(&self, req: Req) -> PipelineCall<Req, Res, Err>

Returns an owned future that waits for readiness and calls the service.

The returned future does not borrow this binding and can be moved between local tasks. The readiness check is skipped if the last pipeline readiness check succeeded and no call has started since; this is decided when the future is first polled.

Trait Implementations

impl<Req, Res, Err> Clone for PipelineBinding<Req, Res, Err>

fn clone(&self) -> PipelineBinding<Req, Res, Err>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Req, Res, Err> Debug for PipelineBinding<Req, Res, Err>

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

Formats the value using the given formatter.

impl<Req, Res, Err> Drop for PipelineBinding<Req, Res, Err>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.