I was wandering if we could have a method to fork/split/broadcast/unzip/switch a Stream into two Streams. We do have a unzip now, but it returns two container, which is not symmetric to zip.
fn unzip() -> (LeftStream<L>, RightStream<R>) where Self: Stream<(L, R)>
fn switch(test: T => bool) -> (TrueStream<T>, FalseStream<T>)
yoshuawuyts
commented
4 years ago
I was wandering if we could have a method to
fork/split/broadcast/unzip/switcha Stream into two Streams. We do have aunzipnow, but it returns two container, which is not symmetric tozip.fn unzip() -> (LeftStream<L>, RightStream<R>) where Self: Stream<(L, R)>fn switch(test: T => bool) -> (TrueStream<T>, FalseStream<T>)related works: #543
https://docs.rs/broadcaster/1.0.0/broadcaster/