Filter the stream

async-streams/src/main.rs

@@ -2,12 +2,15 @@ use trpl::StreamExt;
 
 fn main() {
     trpl::run(async {
-        let values = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10];
+        let values = 1..101;
-        let iter = values.iter().map(|n| n * 2);
+        let iter = values.map(|n| n * 2);
-        let mut stream = trpl::stream_from_iter(iter);
+        let stream = trpl::stream_from_iter(iter);
 
-        while let Some(value) = stream.next().await {
+        let mut filtered =
+            stream.filter(|value| value % 3 == 0 || value % 5 == 0);
+
+        while let Some(value) = filtered.next().await {
             println!("The value was: {value}");
         }
     });
-}
+}