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.

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 as_boxfn(&self) -> Box<dyn Fn(T) + Send + Sync + 'static>

pub async fn listen_once(&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.

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

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