Struct tower_reconnect::Reconnect

pub struct Reconnect<M, Target> where
    M: Service<Target>,  { /* fields omitted */ }

Methods

impl<M, Target> Reconnect<M, Target> where
    M: Service<Target>, 

pub fn new<S, Request>(mk_service: M, target: Target) -> Self where
    M: Service<Target, Response = S>,
    S: Service<Request>,
    Box<dyn Error + Send + Sync>: From<M::Error> + From<S::Error>,
    Target: Clone, 

Trait Implementations

impl<M, Target> Debug for Reconnect<M, Target> where
    M: Service<Target> + Debug,
    M::Future: Debug,
    M::Response: Debug,
    Target: Debug, 

fn fmt(&self, fmt: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<M, Target, S, Request> Service<Request> for Reconnect<M, Target> where
    M: Service<Target, Response = S>,
    S: Service<Request>,
    M::Future: Unpin,
    Box<dyn Error + Send + Sync>: From<M::Error> + From<S::Error>,
    Target: Clone, 

type Response = S::Response

Responses given by the service.

type Error = Box<dyn Error + Send + Sync>

Errors produced by the service.

type Future = ResponseFuture<S::Future>

The future response value.

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

Returns Ready when the service is able to process requests.

fn call(&mut self, request: Request) -> Self::Future

Process the request and return the response asynchronously.