Struct h2::proto::connection::Connection

pub(crate) struct Connection<T, P, B: Buf = Bytes>where
    P: Peer,{
    codec: Codec<T, Prioritized<B>>,
    inner: ConnectionInner<P, B>,
}

An H2 connection

Fields

codec: Codec<T, Prioritized<B>>

Read / write frame values

inner: ConnectionInner<P, B>

Implementations

impl<T, P, B> Connection<T, P, B>where T: AsyncRead + AsyncWrite + Unpin, P: Peer, B: Buf,

pub fn new( codec: Codec<T, Prioritized<B>>, config: Config ) -> Connection<T, P, B>

pub(crate) fn set_target_window_size(&mut self, size: u32)

connection flow control

pub(crate) fn set_initial_window_size( &mut self, size: u32 ) -> Result<(), UserError>

Send a new SETTINGS frame with an updated initial window size.

pub(crate) fn set_enable_connect_protocol(&mut self) -> Result<(), UserError>

Send a new SETTINGS frame with extended CONNECT protocol enabled.

pub(crate) fn max_send_streams(&self) -> usize

Returns the maximum number of concurrent streams that may be initiated by this peer.

pub(crate) fn max_recv_streams(&self) -> usize

Returns the maximum number of concurrent streams that may be initiated by the remote peer.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Error>>

Returns Ready when the connection is ready to receive a frame.

Returns Error as this may raise errors that are caused by delayed processing of received frames.

fn poll_go_away(&mut self, cx: &mut Context<'_>) -> Poll<Option<Result<Reason>>>

Send any pending GOAWAY frames.

This will return Some(reason) if the connection should be closed afterwards. If this is a graceful shutdown, this returns None.

pub fn go_away_from_user(&mut self, e: Reason)

fn take_error( &mut self, ours: Reason, initiator: Initiator ) -> Result<(), Error>

pub fn maybe_close_connection_if_no_streams(&mut self)

Closes the connection by transitioning to a GOAWAY state iff there are no streams or references

pub(crate) fn take_user_pings(&mut self) -> Option<UserPings>

pub fn poll(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Error>>

Advances the internal state of the connection.

fn poll2(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Error>>

fn clear_expired_reset_streams(&mut self)

impl<T, B> Connection<T, Peer, B>where T: AsyncRead + AsyncWrite, B: Buf,

pub(crate) fn streams(&self) -> &Streams<B, Peer>

impl<T, B> Connection<T, Peer, B>where T: AsyncRead + AsyncWrite + Unpin, B: Buf,

pub fn next_incoming(&mut self) -> Option<StreamRef<B>>

pub fn go_away_gracefully(&mut self)

Trait Implementations

impl<T: Debug, P, B: Debug + Buf> Debug for Connection<T, P, B>where P: Peer + Debug,

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

Formats the value using the given formatter.

impl<T, P, B> Drop for Connection<T, P, B>where P: Peer, B: Buf,

fn drop(&mut self)

Executes the destructor for this type.