Struct TimeoutConnector

pub struct TimeoutConnector<T> { /* private fields */ }

A connector that enforces a connection timeout

Implementations

impl<T> TimeoutConnector<T>

where T: Service<Uri> + Send, T::Response: Read + Write + Send + Unpin, T::Future: Send + 'static, T::Error: Into<Box<dyn Error + Send + Sync>>,

pub fn new(connector: T) -> Self

Construct a new TimeoutConnector with a given connector implementing the Connect trait

impl<T> TimeoutConnector<T>

pub fn set_connect_timeout(&mut self, val: Option<Duration>)

Set the timeout for connecting to a URL.

Default is no timeout.

pub fn set_read_timeout(&mut self, val: Option<Duration>)

Set the timeout for the response.

Default is no timeout.

pub fn set_write_timeout(&mut self, val: Option<Duration>)

Set the timeout for the request.

Default is no timeout.

pub fn set_reset_reader_on_write(&mut self, reset: bool)

Reset on the reader timeout on write

This will reset the reader timeout when a write is done through the the TimeoutReader. This is useful when you don’t want to trigger a reader timeout while writes are still be accepted.

Trait Implementations

impl<T: Clone> Clone for TimeoutConnector<T>

fn clone(&self) -> TimeoutConnector<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Connection for TimeoutConnector<T>

where T: Read + Write + Connection + Service<Uri> + Send + Unpin, T::Response: Read + Write + Send + Unpin, T::Future: Send + 'static, T::Error: Into<Box<dyn Error + Send + Sync>>,

fn connected(&self) -> Connected

Return metadata describing the connection.

impl<T: Debug> Debug for TimeoutConnector<T>

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

Formats the value using the given formatter.

impl<T> Service<Uri> for TimeoutConnector<T>

where T: Service<Uri> + Send, T::Response: Read + Write + Connection + Send + Unpin, T::Future: Send + 'static, T::Error: Into<Box<dyn Error + Send + Sync>>,

type Response = Pin<Box<TimeoutStream<<T as Service<Uri>>::Response>>>

Responses given by the service.

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

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<TimeoutConnector<T> as Service<Uri>>::Response, <TimeoutConnector<T> as Service<Uri>>::Error>> + Send>>

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, dst: Uri) -> Self::Future

Process the request and return the response asynchronously.