Struct OnLeft

pub struct OnLeft<Service, Fallback, Req> { /* private fields */ }

Available on crate feature tower only.

LeftPayloadをhandleするServiceです。

Trait Implementations

impl<Service: Clone, Fallback: Clone, Req: Clone> Clone for OnLeft<Service, Fallback, Req>

fn clone(&self) -> OnLeft<Service, Fallback, Req>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Service: Debug, Fallback: Debug, Req: Debug> Debug for OnLeft<Service, Fallback, Req>

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

Formats the value using the given formatter.

impl<State, Service, Fallback> Service<(State, Event)> for OnLeft<Service, Fallback, (State, LeftPayload)>

where Service: Service<(State, LeftPayload), Response = ()>, Service::Error: Into<Box<dyn Error + Send + Sync + 'static>>, Fallback: Service<(State, Event), Response = (), Error = Error>,

type Response = ()

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Either<WrapErrorFuture<<Service as Service<(State, LeftPayload)>>::Future, <Service as Service<(State, LeftPayload)>>::Error>, <Fallback as Service<(State, Event)>>::Future>

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: (State, Event)) -> Self::Future

Process the request and return the response asynchronously.

impl<State, Service, Fallback> Service<(State, Event)> for OnLeft<Service, Fallback, LeftPayload>

where Service: Service<LeftPayload, Response = ()>, Service::Error: Into<Box<dyn Error + Send + Sync + 'static>>, Fallback: Service<(State, Event), Response = (), Error = Error>,

type Response = ()

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Either<WrapErrorFuture<<Service as Service<LeftPayload>>::Future, <Service as Service<LeftPayload>>::Error>, <Fallback as Service<(State, Event)>>::Future>

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: (State, Event)) -> Self::Future

Process the request and return the response asynchronously.

impl<Service, Fallback> Service<Event> for OnLeft<Service, Fallback, LeftPayload>

where Service: Service<LeftPayload, Response = ()>, Service::Error: Into<Box<dyn Error + Send + Sync + 'static>>, Fallback: Service<Event, Response = (), Error = Error>,

type Response = ()

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Either<WrapErrorFuture<<Service as Service<LeftPayload>>::Future, <Service as Service<LeftPayload>>::Error>, <Fallback as Service<Event>>::Future>

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: Event) -> Self::Future

Process the request and return the response asynchronously.