Struct regulatory_region_lib::pub_sub_hub::PubSubHub

pub struct PubSubHub { /* private fields */ }

A rendezvous point for publishers and subscribers.

Implementations

impl PubSubHub

pub fn new(storage_path: PathBuf) -> Self

pub fn publish<S>(&self, new_value: S)

where S: Into<String>,

Publishes new_value.

• All pending futures are woken.
• Later calls to watch_for_change() will be evaluated against new_value.

pub fn watch_for_change<S>(&self, last_value: Option<S>) -> PubSubFuture<'_>

where S: Into<String>,

Watches the value stored in this hub, resolving when the stored value differs from last_value.

pub fn get_value(&self) -> Option<String>