Struct ConnectionInner

pub struct ConnectionInner<C, B>
where
    C: Connection<B>,
    B: Buf,
{
    pub shared: Arc<SharedState>,
    pub conn: C,
    pub send_grease_frame: bool,
    pub config: Config,
    /* private fields */
}

Available on crate feature h3 only.

Fields

shared: Arc<SharedState>

conn: C

TODO: breaking encapsulation just to see if we can get this to work, will fix before merging

send_grease_frame: bool

config: Config

Implementations

impl<C, B> ConnectionInner<C, B>

where C: Connection<B>, B: Buf,

This trait is implemented for all types which can close the connection

pub fn handle_connection_error<T>(&mut self, error: T) -> ConnectionError

where T: Into<ErrorOrigin>,

Handle errors on the connection, closes the connection if needed

This can be a ConnectionErrorIncoming or a InternalConnectionError

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

Polls for the connection error

Returns an Result to allow using ? in the calling function

pub fn close_connection(&mut self, code: Code, reason: String)

Close the connection

impl<B, C> ConnectionInner<C, B>

where C: Connection<B>, B: Buf,

pub async fn send_control_stream_headers( &mut self, ) -> Result<(), ConnectionError>

Sends the settings and initializes the control streams

pub async fn new( conn: C, shared: Arc<SharedState>, config: Config, ) -> Result<ConnectionInner<C, B>, ConnectionError>

Initiates the connection and opens a control stream

pub async fn shutdown<T>( &mut self, sent_closing: &mut Option<T>, max_id: T, ) -> Result<(), ConnectionError>

where T: From<VarInt> + PartialOrd + Copy, VarInt: From<T>,

Send GOAWAY with specified max_id, iff max_id is smaller than the previous one.

pub fn poll_accept_bi( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<<C as OpenStreams<B>>::BidiStream, ConnectionError>>

pub fn poll_accept_recv( &mut self, cx: &mut Context<'_>, ) -> Result<(), ConnectionError>

Polls incoming streams

Accepted streams which are not control, decoder, or encoder streams are buffer in accepted_recv_streams

pub fn poll_control( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<Frame<PayloadLen>, ConnectionError>>

Waits for the control stream to be received and reads subsequent frames.

pub fn accepted_streams_mut(&mut self) -> &mut AcceptedStreams<C, B>

Trait Implementations

impl<B, C> ConnectionState for ConnectionInner<C, B>

where C: Connection<B>, B: Buf,

fn shared_state(&self) -> &SharedState

Get the shared state

fn get_conn_error(&self) -> Option<ErrorOrigin>

Get the connection error if the connection is in error state because of another task

fn set_conn_error(&self, error: ErrorOrigin) -> ErrorOrigin

tries to set the connection error

fn set_conn_error_and_wake<T>(&self, error: T) -> ErrorOrigin

where T: Into<ErrorOrigin>,

set the connection error and wake the connection

fn settings(&self) -> Cow<'_, Settings>

Get the settings

fn set_closing(&self)

Set the connection to closing

fn is_closing(&self) -> bool

Check if the connection is closing

fn set_settings(&self, settings: Settings)

Set the settings

fn waker(&self) -> &AtomicWaker

Returns the waker for the connection