Struct tokio_middleware::Timeout

pub struct Timeout<S> { /* fields omitted */ }

Abort requests that are taking too long

Methods

impl<S> Timeout<S>

pub fn new(upstream: S, timer: Timer, duration: Duration) -> Timeout<S>

Crate a new Timeout with the given upstream service.

Requests will be limited to duration and aborted once the limit has been reached.

Trait Implementations

impl<S: Clone> Clone for Timeout<S>

fn clone(&self) -> Timeout<S>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S, E> Service for Timeout<S> where
    S: Service<Error = E>,
    E: From<TimeoutError<S::Future>>, 

type Request = S::Request

Requests handled by the service.

type Response = S::Response

Responses given by the service.

type Error = S::Error

Errors produced by the service.

type Future = Timeout<S::Future>

The future response value.

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

Process the request and return the response asynchronously.