Struct TimeoutBody

pub struct TimeoutBody<B> { /* private fields */ }

Middleware that applies a timeout to request and response bodies.

Wrapper around a http_body::Body to time out if data is not ready within the specified duration.

Bodies must produce data at most within the specified timeout. If the body does not produce a requested data frame within the timeout period, it will return an error.

Differences from [Timeout][crate::timeout::Timeout]

[Timeout][crate::timeout::Timeout] applies a timeout to the request future, not body. That timeout is not reset when bytes are handled, whether the request is active or not. Bodies are handled asynchronously outside of the tower stack’s future and thus needs an additional timeout.

This middleware will return a TimeoutError.

Example

use bytes::Bytes;
use std::time::Duration;
use rama_http::{Request, Response};
use rama_http::dep::http_body_util::Full;
use rama_http::layer::timeout::RequestBodyTimeoutLayer;
use rama_core::{Layer, service::service_fn};

async fn handle(_: Request<Full<Bytes>>) -> Result<Response<Full<Bytes>>, std::convert::Infallible> {
    // ...
}

let svc = RequestBodyTimeoutLayer::new(
    // Timeout bodies after 30 seconds of inactivity
    Duration::from_secs(30)
).layer(service_fn(handle));

Implementations

impl<B> TimeoutBody<B>

pub fn new(timeout: Duration, body: B) -> TimeoutBody<B>

Creates a new TimeoutBody.

Trait Implementations

impl<B> Body for TimeoutBody<B>

where B: Body, <B as Body>::Error: Into<Box<dyn Error + Send + Sync>>,

type Data = <B as Body>::Data

Values yielded by the Body.

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

The error type this Body might generate.

fn poll_frame( self: Pin<&mut TimeoutBody<B>>, cx: &mut Context<'_>, ) -> Poll<Option<Result<Frame<<TimeoutBody<B> as Body>::Data>, <TimeoutBody<B> as Body>::Error>>>

Attempt to pull out the next data buffer of this stream.

fn is_end_stream(&self) -> bool

Returns true when the end of stream has been reached.

fn size_hint(&self) -> SizeHint

Returns the bounds on the remaining length of the stream.

impl<'__pin, B> Unpin for TimeoutBody<B>

where <PinnedFieldsOfHelperStruct<__Origin<'__pin, B>> as PinnedFieldsOfHelperTrait>::Actual: Unpin,