Trait SubscriptionQuery

pub trait SubscriptionQuery<T>: Send + Sync {
    // Required method
    fn subscribers_by_topic(&self, topic: &Topic) -> Vec<SubscriberRef<T>> ;
}

Required Methods

fn subscribers_by_topic(&self, topic: &Topic) -> Vec<SubscriberRef<T>>

Implementors

impl<T> SubscriptionQuery<T> for DefaultSubscribeManager<T>

where T: Transport,