Struct AtomicBus 

pub struct AtomicBus<T> { /* private fields */ }

A bus, which can send data to a set of active subscriptions.

Data Lifetime

All underlying data is wrapped in an Arc which will be dropped immediately after all active subscribers have dropped their respective references.

Sync

AtomicBus is Sync, so it can be wrapped in an Arc to safely share between threads.

Implementations

impl<T> AtomicBus<T>

pub fn new() -> Self

Create a new AtomicBus

pub fn send<A: Into<Arc<T>>>(&self, data: A)

Send an event to the AtomicBus which will be received by all current subscribers.

Alternatives

If you wish to limit code to be publish-only, see [AtomicBus::sender] to create a send-only struct for this bus.

pub fn create_sender(&self) -> AtomicSender<T>

Create a send-only structure to produce messages to this bus.

pub fn subscribe(&self) -> AtomicSubscription<T>

Create an atomic subscription to this bus, which is Sync and can be shared between threads.

pub fn subscribe_mut(&self) -> MutSubscription<T>

Create a mutable subscription to this bus, which is slightly faster than the atomic variant but is not Sync.

Trait Implementations

impl<T> Default for AtomicBus<T>

fn default() -> Self

Returns the “default value” for a type.