Struct my_iot::core::bus::Bus

pub struct Bus {
    service_txs: Vec<Sender<Message>>,
    tx: Sender<Message>,
    rx: Receiver<Message>,
}

Fields

service_txs: Vec<Sender<Message>>

Service message inbox senders.

tx: Sender<Message>

The bus message inbox sender.

rx: Receiver<Message>

The bus message inbox receiver.

Methods

impl Bus

pub fn new() -> Self

pub fn add_tx(&self) -> Sender<Message>

Get a new message sender. Essentially, it makes a clone of the bus inbox.

pub fn add_rx(&mut self) -> Receiver<Message>

Get a new receiver to subscribe to the bus.

pub fn spawn(self) -> Result<(), Error>

Spawn the bus dispatcher thread.