Crate stream_utils

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);

Structs

• CopiedMultiStream
  Stream for the copied_multi_stream method.

Traits

• StreamUtils
  A Stream blanket implementation trait that provides extra adaptors.

Functions

• copied_multi_stream
  Copies values from the inner stream into multiple new streams. Polls from inner stream one value and waits till all new streams have pulled a copied value. Note that not pulling from all new streams will result in a blocking state.