Struct Connection

pub struct Connection<T, B>
where
    T: AsyncRead + AsyncWrite + Unpin + Send + 'static,
    B: Body + Send + 'static + Unpin,
    <B as Body>::Data: Send + 'static,
    <B as Body>::Error: Into<Box<dyn Error + Sync + Send>>,
{ /* private fields */ }

A future that processes all HTTP state for the IO object.

In most cases, this should just be spawned into an executor, so that it can process incoming and outgoing messages, notice hangups, and the like.

Instances of this type are typically created via the handshake function

Implementations

impl<T, B> Connection<T, B>

where T: AsyncRead + AsyncWrite + Unpin + Send + 'static, B: Body + Send + 'static + Unpin, <B as Body>::Data: Send + 'static, <B as Body>::Error: Into<Box<dyn Error + Sync + Send>>,

pub fn is_extended_connect_protocol_enabled(&self) -> bool

Returns whether the extended CONNECT protocol is enabled or not.

This setting is configured by the server peer by sending the SETTINGS_ENABLE_CONNECT_PROTOCOL parameter in a SETTINGS frame. This method returns the currently acknowledged value received from the remote.

Trait Implementations

impl<T, B> Debug for Connection<T, B>

where T: AsyncRead + AsyncWrite + Debug + Send + 'static + Unpin, B: Body + Send + 'static + Unpin, <B as Body>::Data: Send + 'static, <B as Body>::Error: Into<Box<dyn Error + Sync + Send>>,

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

Formats the value using the given formatter.

impl<T, B> Future for Connection<T, B>

where T: AsyncRead + AsyncWrite + Unpin + Send + 'static, B: Body + Send + 'static + Unpin, <B as Body>::Data: Send + 'static, <B as Body>::Error: Into<Box<dyn Error + Sync + Send>>,

type Output = Result<(), Error>

The type of value produced on completion.

fn poll( self: Pin<&mut Connection<T, B>>, cx: &mut Context<'_>, ) -> Poll<<Connection<T, B> as Future>::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.