Struct ProtoHttp1ClientLayer 

pub struct ProtoHttp1ClientLayer<Svc>
where
    Svc: Service<(ReadHalf<SimplexStream>, WriteHalf<SimplexStream>), Response = ()> + Send + Clone,
{ /* private fields */ }

A service to process HTTP/1.1 requests

This should not be constructed directly - it gets created by MakeService during invocation.

Implementations

impl<Svc> ProtoHttp1ClientLayer<Svc>

where Svc: Service<(ReadHalf<SimplexStream>, WriteHalf<SimplexStream>), Response = ()> + Send + Clone,

pub fn new(config: ProtoHttp1ClientConfig, inner: Svc) -> Self

Create a new instance of the service

Trait Implementations

impl<Svc, SvcError, SvcFut> Service<HTTP1Request> for ProtoHttp1ClientLayer<Svc>

where Svc: Service<(ReadHalf<SimplexStream>, WriteHalf<SimplexStream>), Response = (), Error = SvcError, Future = SvcFut> + Send + Clone + 'static, SvcFut: Future<Output = Result<(), SvcError>> + Send,

type Response = HTTP1ClientResponse<ReadHalf<SimplexStream>, WriteHalf<SimplexStream>>

The response is handled by the protocol

type Error = ProtoHttp1LayerError<SvcError>

Errors would be failures in parsing the protocol - this should be handled by the protocol

type Future = Pin<Box<dyn Future<Output = Result<<ProtoHttp1ClientLayer<Svc> as Service<HTTP1Request>>::Response, <ProtoHttp1ClientLayer<Svc> as Service<HTTP1Request>>::Error>> + Send>>

The future is the protocol itself

fn call(&mut self, request: HTTP1Request) -> Self::Future

Indefinitely process the protocol

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

Returns Poll::Ready(Ok(())) when the service is able to process requests.