Struct libp2p::gossipsub::subscription_filter::AllowAllSubscriptionFilter [−][src]
pub struct AllowAllSubscriptionFilter {}
Expand description
Allows all subscriptions
Trait Implementations
Returns the “default value” for a type. Read more
Returns true iff the topic is of interest and we can subscribe to it.
fn filter_incoming_subscriptions(
&mut self,
subscriptions: &'a [GossipsubSubscription],
currently_subscribed_topics: &BTreeSet<TopicHash>
) -> Result<HashSet<&'a GossipsubSubscription, RandomState>, String>
fn filter_incoming_subscriptions(
&mut self,
subscriptions: &'a [GossipsubSubscription],
currently_subscribed_topics: &BTreeSet<TopicHash>
) -> Result<HashSet<&'a GossipsubSubscription, RandomState>, String>
Filters a list of incoming subscriptions and returns a filtered set
By default this deduplicates the subscriptions and calls
Self::filter_incoming_subscription_set
on the filtered set. Read more
fn filter_incoming_subscription_set(
&mut self,
subscriptions: HashSet<&'a GossipsubSubscription, RandomState>,
_currently_subscribed_topics: &BTreeSet<TopicHash>
) -> Result<HashSet<&'a GossipsubSubscription, RandomState>, String>
fn filter_incoming_subscription_set(
&mut self,
subscriptions: HashSet<&'a GossipsubSubscription, RandomState>,
_currently_subscribed_topics: &BTreeSet<TopicHash>
) -> Result<HashSet<&'a GossipsubSubscription, RandomState>, String>
Filters a set of deduplicated subscriptions
By default this filters the elements based on Self::allow_incoming_subscription
. Read more
Returns true iff we allow an incoming subscription. This is used by the default implementation of filter_incoming_subscription_set to decide whether to filter out a subscription or not. By default this uses can_subscribe to decide the same for incoming subscriptions as for outgoing ones. Read more
Auto Trait Implementations
impl RefUnwindSafe for AllowAllSubscriptionFilter
impl Send for AllowAllSubscriptionFilter
impl Sync for AllowAllSubscriptionFilter
impl Unpin for AllowAllSubscriptionFilter
impl UnwindSafe for AllowAllSubscriptionFilter
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn vzip(self) -> V