Struct ripb::Bus

pub struct Bus { /* fields omitted */ }

An in process bus.

You can create a bus with the [new] method, then create new Subscribers with the [create_subscriber] method, and push some messages on the bus with the [publish] method. If you need to send messages from multiple threads, [clone] the bus and use one instance per thread

Methods

impl Bus

pub fn new() -> Self

Create a new bus, with a thread count equal to the number of CPUs

pub fn with_thread_count(thread_count: NonZeroUsize) -> Self

Create a new bus with the given thread count

pub fn create_subscriber(&self) -> Subscriber

Create a new subscriber for this bus

pub fn publish<M: Message + 'static>(&self, message: M)

Publish a new message on this bus

Trait Implementations

impl Clone for Bus

fn clone(&self) -> Bus

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Drop for Bus

fn drop(&mut self)

Executes the destructor for this type.