stream-more

More utils to operate Stream in rust

StreamMore

StreamMore extends the functionality of Streams, providing additional methods for merging and sorting.

Features

• kmerge_by: creates a k-way merge Stream by merging the given Streams according to a provided closure function.

• kmerge_max: merges Streams by choosing the "greatest" item.

• kmerge_min: merges Streams by choosing the "smallest" item.

Examples

Here are some examples of how to use the functions provided by StreamMore.

Merge streams in customized order:

```rust use futures::StreamExt; use futures::executor::blockon; use futures::stream::iter; use streammore::StreamMore;

let x = iter([1, 3]); let y = iter([2, 4]);

let m = x.kmerge_by(|a,b| a < b) .merge(y);

let got = blockon(m.collect::>()); asserteq!(vec![1, 2, 3, 4], got); ```

Merge and choose smallest item:

```rust let x = iter([3, 2]); let y = iter([4, 1]); let z = iter([5]);

let m = x.kmerge_min() .merge(y) .merge(z);

let got = blockon(m.collect::>()); asserteq!(vec![1, 2, 3, 4, 5], got); ```