Struct libp2p_core::nodes::collection::CollectionStream

pub struct CollectionStream<TInEvent, TOutEvent, THandler, TReachErr, THandlerErr> { /* fields omitted */ }

Implementation of Stream that handles a collection of nodes.

Methods

impl<TInEvent, TOutEvent, THandler, TReachErr, THandlerErr> CollectionStream<TInEvent, TOutEvent, THandler, TReachErr, THandlerErr>

pub fn new() -> Self

Creates a new empty collection.

pub fn add_reach_attempt<TFut, TMuxer>(     &mut self,     future: TFut,     handler: THandler ) -> ReachAttemptId where     TFut: Future<Item = (PeerId, TMuxer), Error = TReachErr> + Send + 'static,     THandler: IntoNodeHandler + Send + 'static,     THandler::Handler: NodeHandler<Substream = Substream<TMuxer>, InEvent = TInEvent, OutEvent = TOutEvent, Error = THandlerErr> + Send + 'static,     <THandler::Handler as NodeHandler>::OutboundOpenInfo: Send + 'static,     TReachErr: Error + Send + 'static,     THandlerErr: Error + Send + 'static,     TInEvent: Send + 'static,     TOutEvent: Send + 'static,     TMuxer: StreamMuxer + Send + Sync + 'static,     TMuxer::OutboundSubstream: Send + 'static,

Adds to the collection a future that tries to reach a remote.

This method spawns a task dedicated to resolving this future and processing the node's events.

pub fn interrupt(&mut self, id: ReachAttemptId) -> Result<(), InterruptError>

Interrupts a reach attempt.

Returns Ok if something was interrupted, and Err if the ID is not or no longer valid.

pub fn broadcast_event(&mut self, event: &TInEvent) where     TInEvent: Clone,

Sends an event to all nodes.

pub fn peer_mut(&mut self, id: &PeerId) -> Option<PeerMut<TInEvent>>

Grants access to an object that allows controlling a peer of the collection.

Returns None if we don't have a connection to this peer.

pub fn has_connection(&self, id: &PeerId) -> bool

Returns true if we are connected to the given peer.

This will return true only after a NodeReached event has been produced by poll().

pub fn connections(     &self ) -> impl Iterator<Item = &PeerId>

Returns a list of all the active connections.

Does not include reach attempts that haven't reached any target yet.

pub fn poll(     &mut self ) -> Async<CollectionEvent<TInEvent, TOutEvent, THandler, TReachErr, THandlerErr>>

Provides an API similar to Stream, except that it cannot error.

Note: we use a regular poll method instead of implementing Stream in order to remove the Err variant, but also because we want the CollectionStream to stay borrowed if necessary.

Trait Implementations

impl<TInEvent, TOutEvent, THandler, TReachErr, THandlerErr> Debug for CollectionStream<TInEvent, TOutEvent, THandler, TReachErr, THandlerErr>

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

Formats the value using the given formatter.