Struct tower_pipeline::Pipeline

pub struct Pipeline<A, B> { /* fields omitted */ }

Two services combined where the response of the first is the request of the second.

Implementations

impl<A, B> Pipeline<A, B>

pub fn new(first: A, second: B) -> Self

Create a new Pipeline from two Services.

pub fn first_as_ref(&self) -> &A

Get a reference to the first service.

pub fn first_as_mut(&mut self) -> &mut A

Get a mutable reference to the first service.

pub fn into_first(self) -> A

Consume self, returning the first service

pub fn second_as_ref(&self) -> &B

Get a reference to the second service.

pub fn second_as_mut(&mut self) -> &mut B

Get a mutable reference to the second service.

pub fn into_second(self) -> B

Consume self, returning the second service

Trait Implementations

impl<A: Clone, B: Clone> Clone for Pipeline<A, B>

fn clone(&self) -> Pipeline<A, B>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<A: Copy, B: Copy> Copy for Pipeline<A, B>

impl<A: Debug, B: Debug> Debug for Pipeline<A, B>

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

Formats the value using the given formatter.

impl<A: Default, B: Default> Default for Pipeline<A, B>

fn default() -> Pipeline<A, B>

Returns the "default value" for a type.

impl<R, A, B> Service<R> for Pipeline<A, B> where
    A: Service<R>,
    B: Service<A::Response> + Clone,
    A::Error: Into<B::Error>, 

type Response = B::Response

Responses given by the service.

type Error = B::Error

Errors produced by the service.

type Future = ResponseFuture<R, A, B>

The future response value.

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

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: R) -> Self::Future

Process the request and return the response asynchronously.