Stream-based programming in Rust