use futures::stream::StreamExt;
use tokio::sync::mpsc::{channel, Receiver, Sender};
use tokio_stream::wrappers::ReceiverStream;

#[tokio::main]
async fn main() {
    let v: Vec<String> = vec!["1".into(), "2".into(), "3".into()];

    let (tx, rx): (Sender<String>, Receiver<String>) = channel(3);

    let f = tokio::spawn(async move {
        ReceiverStream::new(rx)
            .for_each_concurrent(3, |val| {
                let val = val.clone();
                async {  // <-- This needs to be move
                    println!("Processed value: {}", val.clone());
                }
            })
            .await;
    });

    for i in v.iter() {
        tx.send(i.clone()).await.unwrap();
    }

    drop(tx);

    f.await.unwrap();

    println!("Finished");
}