Function my_iot::spawn_dispatcher

fn spawn_dispatcher(
    rx: Receiver<Message>, 
    tx: Sender<Message>, 
    txs: Vec<Sender<Message>>
) -> Result<(), Error>

Spawn message dispatcher that broadcasts every received message to emulate a multi-producer multi-consumer queue.

Thus, services exchange messages with each other. Each message from the input channel is broadcasted to each of output channels.

• rx: dispatcher input message channel
• tx: dispatcher output message channel
• txs: service output message channels