Crate multi_consumer_stream [] [src]

Provides a multi-consumer-stream, that allows to route certain items of a wrapped stream to independent handles.

Structs

MCS

Wraps a stream and provides a multi-consumer-stream.

MCSHandle

A stream that receives all items/errors for which the corresponding MCS's item_fn/err_fn return the key from which the MCSHandle was constructed.