[−][src]Struct libp2p_core::network::peer::ConnectedPeer

pub struct ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId> where
    TTrans: Transport,
    THandler: IntoConnectionHandler<TConnInfo>,  { /* 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
    TTrans: Transport,
    THandler: IntoConnectionHandler<TConnInfo>,
    TConnInfo: ConnectionInfo<PeerId = TPeerId>,
    TPeerId: Eq + Hash + Clone, [src]

pub fn id(&self) -> &TPeerId[src]

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

Returns the ConnectedPeer into a Peer.

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

Obtains an established connection to the peer by ID.

pub fn num_connections(&self) -> usize[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, TConnInfo, TPeerId>>[src]

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

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

Gets an iterator over all established connections to the peer.

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

Obtains some established connection to the peer.

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

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
    TTrans: Transport,
    THandler: IntoConnectionHandler<TConnInfo>,
    TPeerId: Eq + Hash + Debug, [src]

Auto Trait Implementations

impl<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId> !RefUnwindSafe for ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId>

impl<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId> Send for ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId> where
    TConnInfo: Send,
    THandler: Send,
    TInEvent: Send,
    TOutEvent: Send,
    TPeerId: Send,
    TTrans: Send,
    <TTrans as Transport>::Error: Send,
    <<THandler as IntoConnectionHandler<TConnInfo>>::Handler as ConnectionHandler>::Error: Send,
    <THandler as IntoConnectionHandler<TConnInfo>>::Handler: ConnectionHandler,
    <TTrans as Transport>::Listener: Send, 

impl<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId> !Sync for ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId>

impl<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId> Unpin for ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId> where
    TPeerId: Unpin, 

impl<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId> !UnwindSafe for ConnectedPeer<'a, TTrans, TInEvent, TOutEvent, THandler, TConnInfo, TPeerId>

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized, [src]

impl<T> Borrow<T> for T where
    T: ?Sized, [src]

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, [src]

impl<T> Same<T> for T

type Output = T

Should always be Self

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>,