Crate shared_stream[−][src]
A crate for easily cloneable Stream
s, similar to FutureExt::shared
.
Examples
use futures::stream::{self, StreamExt}; use shared_stream::Share; let shared = stream::iter(1..=3).shared(); assert_eq!(shared.clone().take(1).collect::<Vec<_>>().await, [1]); assert_eq!(shared.clone().skip(1).take(1).collect::<Vec<_>>().await, [2]); assert_eq!(shared.collect::<Vec<_>>().await, [1, 2, 3]);
Structs
Shared | Stream for the |
Traits
Share | An extension trait implemented for |