[−][src]Function my_iot::spawn_dispatcher
fn spawn_dispatcher(
rx: Receiver<Message>,
bus: Bus<Message>
) -> Result<(), Error>
Spawn message dispatcher that broadcasts every received message to emulate multi-producer multi-consumer queue. Thus, services exchange messages with each other.