Struct libp2p_core::network::peer::ConnectedPeer [−][src]
pub struct ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler> where
TTrans: Transport,
THandler: IntoConnectionHandler, { /* 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> ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler> where
TTrans: Transport,
THandler: IntoConnectionHandler, [src]
impl<'a, TTrans, TInEvent, TOutEvent, THandler> ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler> where
TTrans: Transport,
THandler: IntoConnectionHandler, [src]pub fn id(&self) -> &PeerId[src]
pub fn into_peer(self) -> Peer<'a, TTrans, TInEvent, TOutEvent, THandler>[src]
Returns the ConnectedPeer into a Peer.
pub fn connection(
&mut self,
id: ConnectionId
) -> Option<EstablishedConnection<'_, TInEvent>>[src]
&mut self,
id: ConnectionId
) -> Option<EstablishedConnection<'_, TInEvent>>
Obtains an established connection to the peer by ID.
pub fn num_connections(&self) -> u32[src]
The number of established connections to the peer.
pub fn is_dialing(&self) -> bool[src]
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>>[src]
self
) -> Option<DialingPeer<'a, TTrans, TInEvent, TOutEvent, THandler>>
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>[src]
&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.
pub fn some_connection(&mut self) -> EstablishedConnection<'_, TInEvent>[src]
Obtains some established connection to the peer.
pub fn disconnect(
self
) -> DisconnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler>[src]
self
) -> DisconnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler>
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,
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,