Struct libp2p::core::network::peer::ConnectedPeer

pub struct ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId> where
    THandler: IntoConnectionHandler<TConnInfo>,
    TTrans: Transport,  { /* fields omitted */ }

The representation of a peer in a [Network] to whom at least one established connection exists. There may also be additional ongoing dialing attempts to the peer.

Implementations

impl<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId> ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId> where
    TConnInfo: ConnectionInfo<PeerId = TPeerId>,
    THandler: IntoConnectionHandler<TConnInfo>,
    TPeerId: Eq + Hash + Clone,
    TTrans: Transport, 

pub fn id(&self) -> &TPeerId

pub fn into_peer(
    self
) -> Peer<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId>

Returns the ConnectedPeer into a Peer.

pub fn connection(
    &'b mut self,
    id: ConnectionId
) -> Option<EstablishedConnection<'b, TInEvent, TConnInfo, TPeerId>>

Obtains an established connection to the peer by ID.

pub fn num_connections(&self) -> usize

The number of established connections to the peer.

pub fn is_dialing(&self) -> bool

Checks whether there is an ongoing dialing attempt to the peer.

Returns true iff [ConnectedPeer::into_dialing] returns Some.

pub fn into_dialing(
    self
) -> Option<DialingPeer<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId>>

Converts this peer into a [DialingPeer], if there is an ongoing dialing attempt, None otherwise.

pub fn connections(
    &'b mut self
) -> EstablishedConnectionIter<'b, impl Iterator<Item = ConnectionId>, TInEvent, TOutEvent, THandler, <TTrans as Transport>::Error, <<THandler as IntoConnectionHandler<TConnInfo>>::Handler as ConnectionHandler>::Error, TConnInfo, TPeerId>

Gets an iterator over all established connections to the peer.

pub fn some_connection(
    &'b mut self
) -> EstablishedConnection<'b, TInEvent, TConnInfo, TPeerId>

Obtains some established connection to the peer.

pub fn disconnect(
    self
) -> DisconnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId>

Disconnects from the peer, closing all connections.

Trait Implementations

impl<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId> Debug for ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId> where
    THandler: IntoConnectionHandler<TConnInfo>,
    TPeerId: Eq + Hash + Debug,
    TTrans: Transport, 

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

Formats the value using the given formatter.