Struct ntex::http::h1::H1ServiceHandler

pub struct H1ServiceHandler<T, S: Service, B, X: Service, U: Service> { /* fields omitted */ }

Service implementation for HTTP1 transport

Trait Implementations

impl<T, S, B, X, U> Service for H1ServiceHandler<T, S, B, X, U> where
    T: AsyncRead + AsyncWrite + Unpin + 'static,
    S: Service<Request = Request>,
    S::Error: ResponseError + 'static,
    S::Response: Into<Response<B>>,
    B: MessageBody,
    X: Service<Request = Request, Response = Request>,
    X::Error: ResponseError + 'static,
    U: Service<Request = (Request, T, IoState, Codec), Response = ()>,
    U::Error: Display + Error + 'static, 

type Request = (T, Option<SocketAddr>)

Requests handled by the service.

type Response = ()

Responses given by the service.

type Error = DispatchError

Errors produced by the service.

type Future = Dispatcher<T, S, B, X, U>

The future response value.

fn poll_ready(&self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Ready when the service is able to process requests.

fn poll_shutdown(&self, cx: &mut Context<'_>, is_error: bool) -> Poll<()>

Shutdown service.

fn call(&self, (io, addr): Self::Request) -> Self::Future

Process the request and return the response asynchronously.

fn map<F, R>(self, f: F) -> Map<Self, F, R> where
    F: FnMut(Self::Response) -> R, 

Map this service’s output to a different type, returning a new service of the resulting type.

fn map_err<F, E>(self, f: F) -> MapErr<Self, F, E> where
    F: Fn(Self::Error) -> E, 

Map this service’s error to a different error, returning a new service.