Struct libp2p_rs::mplex::connection::Connection

pub struct Connection<T> where
    T: SplitEx,  { /* fields omitted */ }

Implementations

impl<T> Connection<T> where
    T: SplittableReadWrite, 

pub fn new(socket: T) -> Connection<T>

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> where
    T: SplitEx, 

pub fn streams_length(&self) -> usize

Trait Implementations

impl<T> Display for Connection<T> where
    T: SplitEx, 

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

Formats the value using the given formatter.