Struct ProtoHttp2Layer 

pub struct ProtoHttp2Layer<Svc>
where
    Svc: Service<(Receiver<Http2Frame>, Sender<Http2Frame>), 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> ProtoHttp2Layer<Svc>

where Svc: Service<(Receiver<Http2Frame>, Sender<Http2Frame>), Response = ()> + Send + Clone,

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

Create a new instance of the service

Trait Implementations

impl<Reader, Writer, Svc, SvcError, SvcFut> Service<(Reader, Writer)> for ProtoHttp2Layer<Svc>

where Reader: AsyncReadExt + Send + Unpin + 'static, Writer: AsyncWriteExt + Send + Unpin + 'static, Svc: Service<(Receiver<Http2Frame>, Sender<Http2Frame>), Response = (), Error = SvcError, Future = SvcFut> + Send + Clone + 'static, SvcFut: Future<Output = Result<(Receiver<Http2Frame>, Sender<Http2Frame>), SvcError>> + Send + 'static, SvcError: Debug + Send + 'static,

type Response = ()

The response is handled by the protocol

type Error = ProtoHttp2Error<SvcError>

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

type Future = Pin<Box<dyn Future<Output = Result<<ProtoHttp2Layer<Svc> as Service<(Reader, Writer)>>::Response, <ProtoHttp2Layer<Svc> as Service<(Reader, Writer)>>::Error>> + Send>>

The future is the protocol itself

fn call(&mut self, (reader, writer): (Reader, Writer)) -> 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.