Struct TimeoutMiddleware 

pub struct TimeoutMiddleware { /* private fields */ }

Timeout middleware

Wraps request processing with a timeout, returning REQUEST_TIMEOUT (408) if the handler doesn’t complete within the configured duration.

Examples

use reinhardt_middleware::timeout::{TimeoutMiddleware, TimeoutConfig};
use std::time::Duration;

let config = TimeoutConfig::new(Duration::from_secs(30));
let middleware = TimeoutMiddleware::new(config);

Implementations

impl TimeoutMiddleware

pub fn new(config: TimeoutConfig) -> Self

Create a new timeout middleware

Examples

use reinhardt_middleware::timeout::{TimeoutMiddleware, TimeoutConfig};
use std::time::Duration;

let config = TimeoutConfig::new(Duration::from_secs(30));
let middleware = TimeoutMiddleware::new(config);

Trait Implementations

impl Middleware for TimeoutMiddleware

fn process<'life0, 'async_trait>( &'life0 self, request: Request, next: Arc<dyn Handler>, ) -> Pin<Box<dyn Future<Output = Result<Response>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Processes a request through this middleware.

fn should_continue(&self, _request: &Request) -> bool

Determines whether this middleware should be executed for the given request.