Struct HttpCoreService

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

Core HTTP service handler supporting both HTTP/1.1 and HTTP/2 protocols.

HttpCoreService is responsible for accepting HTTP connections, decoding requests, routing them through a handler chain, and encoding responses. It supports both HTTP/1.1 with keep-alive and HTTP/2 with multiplexing. For implementation details and example usage, see the module level documentation.

Implementations

impl<H> HttpCoreService<H>

pub fn new(handler_chain: H, http_timeout: HttpServerTimeout) -> Self

impl<F> HttpCoreService<F>

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

where C: Param<HttpServerTimeout>,

Trait Implementations

impl<F: AsyncMakeService> AsyncMakeService for HttpCoreService<F>

type Service = HttpCoreService<<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 HttpCoreService<H>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<F: MakeService> MakeService for HttpCoreService<F>

type Service = HttpCoreService<<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, Stream, CXIn, CXStore, CXState, Err> Service<(bool, Stream, CXIn)> for HttpCoreService<H>

where CXIn: ParamRef<PeerAddr> + Fork<Store = CXStore, State = CXState>, CXStore: 'static, for<'a> CXState: Attach<CXStore>, for<'a> H: HttpHandler<<CXState as Attach<CXStore>>::Hdr<'a>, HttpBody, Body = HttpBody, Error = Err>, Stream: Split + AsyncReadRent + AsyncWriteRent + Unpin + 'static, Err: Into<AnyError> + Debug,

type Response = ()

The type of response returned by this service.

type Error = Infallible

The type of error that this service can produce.

async fn call( &self, incoming_stream: HttpAccept<Stream, CXIn>, ) -> Result<Self::Response, Self::Error>

Asynchronously process the request and return the response.