Struct tower::reconnect::Reconnect

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

This is supported on crate feature reconnect only.

Reconnect to failed services.

Implementations

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

pub fn new<S, Request>(mk_service: M, target: Target) -> Self

Lazily connect and reconnect to a Service.

pub fn with_connection(
    init_conn: M::Response,
    mk_service: M,
    target: Target
) -> Self

Reconnect to a already connected Service.

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,
    BoxError: From<M::Error> + From<S::Error>,
    Target: Clone, 

type Response = S::Response

Responses given by the service.

type Error = BoxError

Errors produced by the service.

type Future = ResponseFuture<S::Future, M::Error>

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, request: Request) -> Self::Future

Process the request and return the response asynchronously.