How do you work with async streams?

Question

Accepted Answer

**Stream** — async iterator.

**Using tokio-stream:**
```rust
use tokio_stream::StreamExt;
use tokio::sync::mpsc;

let (tx, mut rx) = mpsc::channel(32);

tokio::spawn(async move {
    for i in 0..5 {
        tx.send(i).await.unwrap();
        tokio::time::sleep(Duration::from_millis(100)).await;
    }
});

while let Some(value) = rx.recv().await {
    println!("Received: {}", value);
}
```

**Using async-stream:**
```rust
let stream = async_stream::stream! {
    for i in 0..5 {
        tokio::time::sleep(Duration::from_millis(100)).await;
        yield i;
    }
};

let values: Vec<i32> = stream.collect().await;
```

**Key:** Stream for async iteration.

Rust: How do you work with async streams?