Struct subscription_service::SubscriptionService

pub struct SubscriptionService<T, U> {
    pub name: String,
    /* private fields */
}

Fields

name: String

Implementations

impl<T: Clone, U> SubscriptionService<T, U>

pub fn subscribe(name: &str, items: T) -> (Self, Receiver<(), U>)

Constructs an subscription object for items Returns the subscription object, and the receiving end of a channel that subscription will be sent to

pub fn publish(&mut self, payload: U) -> Result<()>

pub fn subscribed_items(&self) -> T

impl SubscriptionService<SubscriptionBundle, OnChainConfigPayload>

pub fn subscribe_all( name: &str, configs: Vec<ConfigID>, events: Vec<EventKey> ) -> (Self, Receiver<(), OnChainConfigPayload>)