Struct HTTP1Request 

pub struct HTTP1Request {
    pub path: Uri,
    pub method: Method,
    pub headers: HeaderMap,
    pub body: Vec<u8>,
}

An HTTP/1.1 request

Fields

path: Uri

method: Method

headers: HeaderMap

body: Vec<u8>

Trait Implementations

impl Clone for HTTP1Request

fn clone(&self) -> HTTP1Request

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HTTP1Request

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

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.

impl<Writer> WriteTo<Writer, ()> for HTTP1Request

where Writer: AsyncWriteExt + Send + Unpin + 'static,

fn write_to<'life0, 'life1, 'async_trait>( &'life0 self, writer: &'life1 mut Writer, ) -> Pin<Box<dyn Future<Output = Result<(), ()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,