Struct ConcurrentDiscovery

pub struct ConcurrentDiscovery { /* private fields */ }

A discovery service that combines multiple discovery sources.

The discovery services will resolve concurrently.

Implementations

impl ConcurrentDiscovery

pub fn empty() -> Self

Creates an empty ConcurrentDiscovery.

pub fn from_services(services: Vec<Box<dyn Discovery>>) -> Self

Creates a new ConcurrentDiscovery.

pub fn add(&mut self, service: impl Discovery + 'static)

Adds a Discovery service.

Trait Implementations

impl Debug for ConcurrentDiscovery

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

Formats the value using the given formatter.

impl Default for ConcurrentDiscovery

fn default() -> ConcurrentDiscovery

Returns the “default value” for a type.

impl Discovery for ConcurrentDiscovery

fn publish(&self, info: &AddrInfo)

Publishes the given AddrInfo to the discovery mechanism.

fn resolve( &self, endpoint: Endpoint, node_id: NodeId, ) -> Option<BoxStream<Result<DiscoveryItem>>>

Resolves the AddrInfo for the given NodeId.

fn subscribe(&self) -> Option<BoxStream<DiscoveryItem>>

Subscribe to all addresses that get passively discovered.

impl<T> From<T> for ConcurrentDiscovery

where T: IntoIterator<Item = Box<dyn Discovery>>,

fn from(iter: T) -> Self

Converts to this type from the input type.