[][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.