Struct PubSub 

pub struct PubSub<T: Clone>(/* private fields */);

A pub/sub struct which allows many listeners to subscribe to many publishers, without leaking callbacks as listeners are dropped.

Unlike mpsc etc., PubSub has no internal queue and is completely synchronous. Explicitly does not implement clone, as this is intended as RAII, even though the internal data structures are Clone because they need to be sent to listeners.

Implementations

impl<T: Clone + 'static> PubSub<T>

pub fn emit(&self, val: T)

Emit a value to all listeners.

Arguments

• val The value to emit.

pub fn callback(&self) -> Callback<T>

Get this PubSub<_>’s .emit_all() method as a Callback<T>.

pub fn add_notify_listener(&self, cb: &Callback<()>) -> Subscription

Subscribe a Callback<()> that fires whenever this PubSub emits, discarding the emitted value. Useful when the subscriber only needs a “something changed” notification.

pub fn as_boxfn(&self) -> Box<dyn Fn(T) + 'static>

Convert PubSub::emit to a Box<dyn Fn(T)>.

pub async fn read_next(&self) -> Result<T, Canceled>

Await this PubSub<_>’s next call to emit_all(), once.

pub fn subscriber(&self) -> Subscriber<T>

Create a Subscriber from this PubSub, which is the reciprocal of PubSub::callback (a struct which only allows sending), a struct which only allows receiving via Subscriber::add_listener.

Trait Implementations

impl<T: Clone + 'static> AddListener<Callback<T>> for PubSub<T>

fn add_listener(&self, f: Callback<T>) -> Subscription

Register a listener to this PubSub<_>, which will be automatically deregistered when the return Subscription is dropped.

impl<T, U> AddListener<U> for PubSub<T>

where T: Clone + 'static, U: Fn(T) + 'static,

fn add_listener(&self, f: U) -> Subscription

Register a listener to this PubSub<_>, which will be automatically deregistered when the return Subscription is dropped.

impl<T: Clone> Default for PubSub<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T: Clone> Drop for PubSub<T>

fn drop(&mut self)

Executes the destructor for this type.