Struct TransientEventBus 

pub struct TransientEventBus<T, R = ()> { /* private fields */ }

Process-local event broadcast paired with an optional shared transport.

The local channel is always available, including in single-process deployments and tests. Products decide how to encode events for R, how to publish through it, and how remote items are decoded back into the local channel.

Implementations

impl<T, R> TransientEventBus<T, R>

where T: Clone,

pub fn new(capacity: usize) -> Self

Creates a process-local bus without a shared transport.

pub fn with_transport(capacity: usize, transport: R) -> Self

Creates a bus with a shared transport.

pub fn from_optional_transport(capacity: usize, transport: Option<R>) -> Self

Creates a bus from an optional shared transport.

pub fn publish_local(&self, event: T) -> Result<usize, SendError<T>>

Publishes one event to process-local subscribers.

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

Subscribes to future process-local events.

pub fn local_subscriber_count(&self) -> usize

Returns the number of active process-local subscribers.

pub fn has_transport(&self) -> bool

Returns whether a shared transport is configured.

pub fn transport(&self) -> Option<Arc<R>>

Returns the shared transport, if configured.

Trait Implementations

impl<T, R> Clone for TransientEventBus<T, R>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.