Trait TopicDiscoveryExt 

pub trait TopicDiscoveryExt {
    // Required methods
    async fn subscribe_with_discovery_joined(
        &self,
        topic_id: Vec<u8>,
        bootstrap_nodes: Vec<EndpointId>,
        config: TopicDiscoveryConfig,
    ) -> Result<(GossipSender, GossipReceiver, TopicDiscoveryHandle)>;
    async fn subscribe_with_discovery(
        &self,
        topic_id: Vec<u8>,
        bootstrap_nodes: Vec<EndpointId>,
        config: TopicDiscoveryConfig,
    ) -> Result<(GossipSender, GossipReceiver, TopicDiscoveryHandle)>;
}

Required Methods

async fn subscribe_with_discovery_joined( &self, topic_id: Vec<u8>, bootstrap_nodes: Vec<EndpointId>, config: TopicDiscoveryConfig, ) -> Result<(GossipSender, GossipReceiver, TopicDiscoveryHandle)>

async fn subscribe_with_discovery( &self, topic_id: Vec<u8>, bootstrap_nodes: Vec<EndpointId>, config: TopicDiscoveryConfig, ) -> Result<(GossipSender, GossipReceiver, TopicDiscoveryHandle)>

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl TopicDiscoveryExt for Gossip

async fn subscribe_with_discovery_joined( &self, topic_id: Vec<u8>, bootstrap_nodes: Vec<EndpointId>, config: TopicDiscoveryConfig, ) -> Result<(GossipSender, GossipReceiver, TopicDiscoveryHandle)>

async fn subscribe_with_discovery( &self, topic_id: Vec<u8>, bootstrap_nodes: Vec<EndpointId>, config: TopicDiscoveryConfig, ) -> Result<(GossipSender, GossipReceiver, TopicDiscoveryHandle)>

Implementors