Crate tokio_stream_util 

Extension traits and utilities for tokio-stream’s Stream trait.

Re-exports

pub use crate::fused::FusedStream;

pub use crate::try_stream::TryStream;

pub use crate::try_stream::TryStreamExt;

pub use futures_ordered::FuturesOrdered;

pub use futures_unordered::FuturesUnordered;

pub use flatten_unordered::FlattenUnordered;

Modules

flatten_unordered

Stream for flattening a stream of streams in an unordered fashion, with ability to specify flow controller. This is a more generic version of FlattenUnordered which allows to control the flow of items from the base stream to the inner streams. The main use-case is to immediately return an item from the base stream without adding it to the inner streams bucket.

fused

A stream which can report whether or not it has terminated.

futures_ordered

An unbounded queue of futures which yields results in submission order. This is similar to FuturesUnordered, but imposes a FIFO order on top of the set of futures.

futures_unordered

An unbounded set of futures.

try_stream

Utilities for working with streams that return Result values.