Enum HttpConnection 

pub enum HttpConnection<K, IO>
where
    K: Key,
    IO: AsyncReadRent + AsyncWriteRent,
{
    Http1(Pooled<K, Http1Connection<IO>>),
    Http2(Http2Connection),
}

A unified representation of an HTTP connection, supporting both HTTP/1.1 and HTTP/2 protocols.

This enum is designed to work with monoio’s native IO traits, which are optimized for io_uring. It allows for efficient handling of both HTTP/1.1 and HTTP/2 connections within the same abstraction.

Variants

Http1(Pooled<K, Http1Connection<IO>>)

Http2(Http2Connection)

Implementations

impl<K, IO> HttpConnection<K, IO>

where K: Key, IO: AsyncReadRent + AsyncWriteRent,

pub async fn send_request<R, E>( &mut self, request: R, ) -> (Result<Response<HttpBody>, HttpError>, bool)

where ClientCodec<IO>: Sink<R, Error = E>, E: Debug + Into<HttpError>, R: IntoParts<Parts = Parts>, <R as IntoParts>::Body: Body<Data = Bytes, Error = HttpError>,

Sends an HTTP request using the appropriate protocol (HTTP/1.1 or HTTP/2).

This method automatically handles the differences between HTTP/1.1 and HTTP/2, providing a unified interface for sending requests.

Arguments

• request - The HTTP request to send.

Returns

A tuple containing:

• Result<Response<HttpBody>, HttpError>: The HTTP response or an error.
• bool: Indicates whether the connection can be reused (true) or should be closed (false).

Type Parameters

• R: The request type, which must be convertible into parts with a RequestHead.
• E: The error type for the ClientCodec, which must be convertible into HttpError.

Examples

let (response, can_reuse) = conn.send_request(request).await;
let response: Response<HttpBody> = response?;
 Ok(())
}

Trait Implementations

impl<K, IO> From<Http2Connection> for HttpConnection<K, IO>

where K: Key, IO: AsyncReadRent + AsyncWriteRent,

fn from(conn: Http2Connection) -> HttpConnection<K, IO>

Converts to this type from the input type.

impl<K, IO> From<Pooled<K, Http1Connection<IO>>> for HttpConnection<K, IO>

where K: Key, IO: AsyncReadRent + AsyncWriteRent,

fn from(pooled_conn: Pooled<K, Http1Connection<IO>>) -> HttpConnection<K, IO>

Converts to this type from the input type.

impl<K, IO> Poolable for HttpConnection<K, IO>

where K: Key, IO: AsyncWriteRent + AsyncReadRent,

fn is_open(&self) -> bool