Struct Connection 

pub struct Connection<T> { /* private fields */ }

Implementations

impl<T: AsyncRead + AsyncWrite + Send + Unpin + 'static> Connection<T>

pub fn new(socket: T) -> Self

Create a new Connection from the given I/O resource.

pub fn id(&self) -> Id

Returns the id of the connection

pub fn control(&self) -> Control

Get a controller for this connection.

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

Get the next incoming stream, opened by the remote.

This must be called repeatedly in order to make progress. Once Ok(())) or Err(_) is returned the connection is considered closed and no further invocation of this method must be attempted.

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

This is called from Connection::next_stream instead of being a public method itself in order to guarantee proper closing in case of an error or at EOF.

impl<T> Connection<T>

pub fn streams_length(&self) -> usize

Trait Implementations

impl<T> Display for Connection<T>

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

Formats the value using the given formatter.