Struct ConnectionReuseHandler

pub struct ConnectionReuseHandler<H> { /* private fields */ }

Handler for managing HTTP connection persistence and keep-alive behavior.

ConnectionReuseHandler is responsible for:

1. Detecting whether an incoming request supports keep-alive.
2. Modifying request and response headers to ensure proper keep-alive behavior.
3. Handling version-specific connection persistence logic for HTTP/1.0, HTTP/1.1, and HTTP/2.

For implementation details and example usage, see the module level documentation.

Implementations

impl<F> ConnectionReuseHandler<F>

pub fn layer<C>() -> impl FactoryLayer<C, F, Factory = Self>

Trait Implementations

impl<F: AsyncMakeService> AsyncMakeService for ConnectionReuseHandler<F>

type Service = ConnectionReuseHandler<<F as AsyncMakeService>::Service>

The type of service this factory creates.

type Error = <F as AsyncMakeService>::Error

The type of error that can occur during service creation.

async fn make_via_ref( &self, old: Option<&Self::Service>, ) -> Result<Self::Service, Self::Error>

Asynchronously creates a new service, optionally using an existing service as a reference.

fn make(&self) -> impl Future<Output = Result<Self::Service, Self::Error>>

Asynchronously creates a new service without referencing an existing one.

impl<H: Clone> Clone for ConnectionReuseHandler<H>

fn clone(&self) -> ConnectionReuseHandler<H>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<F: MakeService> MakeService for ConnectionReuseHandler<F>

type Service = ConnectionReuseHandler<<F as MakeService>::Service>

The type of service this factory creates.

type Error = <F as MakeService>::Error

The type of error that can occur during service creation.

fn make_via_ref( &self, old: Option<&Self::Service>, ) -> Result<Self::Service, Self::Error>

Creates a new service, optionally using an existing service as a reference.

fn make(&self) -> Result<Self::Service, Self::Error>

Creates a new service without referencing an existing one.

impl<H, CX, B> Service<(Request<B>, CX)> for ConnectionReuseHandler<H>

where H: HttpHandler<CX, B>,

type Response = (Response<<H as HttpHandler<CX, B>>::Body>, bool)

The type of response returned by this service.

type Error = <H as HttpHandler<CX, B>>::Error

The type of error that this service can produce.

async fn call( &self, __arg1: (Request<B>, CX), ) -> Result<Self::Response, Self::Error>

Asynchronously process the request and return the response.