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.

pub fn current_max_send_streams(&self) -> usize

Returns the current maximum send stream count.

This setting is configured in a SETTINGS_MAX_CONCURRENT_STREAMS parameter in a SETTINGS frame, and may change throughout the connection lifetime.

pub fn current_max_recv_streams(&self) -> usize

Returns the current maximum receive stream count.

This setting is configured in a SETTINGS_MAX_CONCURRENT_STREAMS parameter in a SETTINGS frame, and may change throughout the connection lifetime.

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 + ExtensionsRef + '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.