Struct libp2p_core::network::peer::ConnectedPeer [−][src]
pub struct ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler> where
TTrans: Transport,
THandler: IntoConnectionHandler, { /* fields omitted */ }Expand description
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> ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler> where
TTrans: Transport,
THandler: IntoConnectionHandler,
impl<'a, TTrans, TInEvent, TOutEvent, THandler> ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler> where
TTrans: Transport,
THandler: IntoConnectionHandler, Returns the ConnectedPeer into a Peer.
Obtains an established connection to the peer by ID.
The number of established connections to the peer.
Checks whether there is an ongoing dialing attempt to the peer.
Returns true iff ConnectedPeer::into_dialing returns Some.
Converts this peer into a DialingPeer, if there is an ongoing
dialing attempt, None otherwise.
pub fn connections(
&mut self
) -> EstablishedConnectionIter<'_, impl Iterator<Item = ConnectionId>, TInEvent, TOutEvent, THandler, TTrans::Error, <THandler::Handler as ConnectionHandler>::Error>
pub fn connections(
&mut self
) -> EstablishedConnectionIter<'_, impl Iterator<Item = ConnectionId>, TInEvent, TOutEvent, THandler, TTrans::Error, <THandler::Handler as ConnectionHandler>::Error>Gets an iterator over all established connections to the peer.
Obtains some established connection to the peer.
Disconnects from the peer, closing all connections.
Trait Implementations
Auto Trait Implementations
impl<'a, TTrans, TInEvent, TOutEvent, THandler> !RefUnwindSafe for ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler>impl<'a, TTrans, TInEvent, TOutEvent, THandler> Send for ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler> where
THandler: Send,
TInEvent: Send,
TOutEvent: Send,
TTrans: Send,
<TTrans as Transport>::Error: Send,
<<THandler as IntoConnectionHandler>::Handler as ConnectionHandler>::Error: Send,
<TTrans as Transport>::Listener: Send, impl<'a, TTrans, TInEvent, TOutEvent, THandler> !Sync for ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler>impl<'a, TTrans, TInEvent, TOutEvent, THandler> Unpin for ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler>impl<'a, TTrans, TInEvent, TOutEvent, THandler> !UnwindSafe for ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler>