Extra Stream adaptors and functions.

To Extend Stream with methods in this crate, import the StreamUtils trait:

use stream_utils::StreamUtils;

Now, new methods like copied_multi_stream are available on all streams.

use futures_util::stream; // or futures::stream;
use stream_utils::StreamUtils;

let stream = stream::iter(0..3);
let streams = stream.copied_multi_stream(4);

Stream-Utils

Additional stream adaptors.

Please read the API documentation here.

Install

Run the following Cargo command in your project directory:

cargo add stream-utils

Or add the following line to your Cargo.toml:

stream-utils = "0.1.0"

License

Licensed under either of Apache License, Version 2.0 or MIT license at your option.