How to Stream Data Asynchronously in Rust

Use the Stream trait with StreamExt to process a sequence of asynchronous items one by one without blocking the runtime. Import StreamExt to access the next method, then loop over the stream using while let and await to handle each item as it arrives.

use trpl::StreamExt;

#[trpl::main]
async fn main() {
    let stream = trpl::stream_from_iter(vec![1, 2, 3].into_iter());
    
    let mut stream = stream;
    while let Some(value) = stream.next().await {
        println!("Received: {}", value);
    }
}

A stream is like a conveyor belt that delivers items to your program one at a time as they become ready, rather than waiting for the whole batch to arrive. This lets your application handle data efficiently as it comes in, similar to reading a book page by page instead of waiting for the entire library to be delivered before starting.