Enum kvarn::application::ResponseBodyPipe

pub enum ResponseBodyPipe {
    Http1(Arc<Mutex<Encryption>>),
    Http2(SendStream<Bytes>, H2SendResponse),
    Http3(RequestStream<SendStream<Bytes>, Bytes>),
}

A pipe to send a body after the Response is sent by ResponsePipe::send_response.

The AsyncWriteExt::shutdown does nothing, and will immediately return with Ok(())

Variants

Http1(Arc<Mutex<Encryption>>)

HTTP/1 pipe

Http2(SendStream<Bytes>, H2SendResponse)

Available on crate feature http2 only.

HTTP/2 pipe

Http3(RequestStream<SendStream<Bytes>, Bytes>)

Available on crate feature http3 only.

HTTP/3 pipe

Implementations

impl ResponseBodyPipe

pub async fn send(&mut self, data: Bytes) -> Result<(), Error>

Sends data as the body.

Errors

Passes any errors from writing to the stream. See AsyncWriteExt::write_all() and [h2::SendStream::send_data()].

pub fn push_request( &mut self, request: Request<()> ) -> Result<PushedResponsePipe, Error>

Pushes request to client.

Errors

If you try to push if self is ResponsePipe::Http1, an Error::UnsupportedPush is returned. Returns errors from [h2::server::SendResponse::push_request()].

pub async fn close(&mut self) -> Result<(), Error>

Closes the pipe.

Errors

Passes any errors emitted when closing the writer. See AsyncWriteExt::flush() and [h2::SendStream::send_data()].

Trait Implementations

impl Debug for ResponseBodyPipe

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

Formats the value using the given formatter.