main.rs

use async_std::{
    stream::StreamExt,
    sync::{channel, Sender, Receiver}
};
use futures::join;

async fn producer_1(sender: Sender<String>) {
    let mut i = 0;
    loop {
        let s = format!("PROD1 {}", i);
        sender.send(s).await;
        i += 1;
    }
}

async fn producer_2(sender: Sender<String>) {
    let mut i = 0;
    loop {
        let s = format!("PROD2 {}", i);
        sender.send(s).await;
        i += 1;
    }
}

async fn producer_3(sender: Sender<String>) {
    let mut i = 0;
    loop {
        let s = format!("PROD3 {}", i);
        sender.send(s).await;
        i += 1;
    }
}


async fn consumer(mut receiver: Receiver<String>) {
    while let Some(msg) = receiver.next().await {
        println!("{:?}", msg);
    }
}

#[async_std::main]
async fn main() {
    let (sender, receiver) = channel(10);

    join!(
        producer_1(sender.clone()),
        producer_2(sender.clone()),
        producer_3(sender),
        consumer(receiver)
    );
}