@@ -791,18 +791,22 @@ extension_trait! {
791
791
# async_std::task::block_on(async {
792
792
793
793
use async_std::prelude::*;
794
- use async_std::stream::IntoStream;
795
794
use async_std::stream;
796
795
797
- let inner1 = stream::from_iter(vec![1,2,3]);
798
- let inner2 = stream::from_iter(vec![4,5,6]);
796
+ let words = stream::from_iter(&["alpha", "beta", "gamma"]);
799
797
800
- let s = stream::from_iter(vec![inner1, inner2]);
798
+ let merged: String = words
799
+ .flat_map(|s| stream::from_iter(s.chars()))
800
+ .collect().await;
801
+ assert_eq!(merged, "alphabetagamma");
801
802
802
- let v :Vec<_> = s.flat_map(|s| s.into_stream()).collect().await;
803
-
804
- assert_eq!(v, vec![1,2,3,4,5,6]);
803
+ let d3 = stream::from_iter(&[[[1, 2], [3, 4]], [[5, 6], [7, 8]]]);
804
+ let d1: Vec<_> = d3
805
+ .flat_map(|item| stream::from_iter(item))
806
+ .flat_map(|item| stream::from_iter(item))
807
+ .collect().await;
805
808
809
+ assert_eq!(d1, [&1, &2, &3, &4, &5, &6, &7, &8]);
806
810
# });
807
811
```
808
812
"# ]
0 commit comments