Crate multi_consumer_stream [−] [src]
This crate provides a wrapper around streams that allow multiple, independent tasks to read from the same underlying stream. Each handle is assigned a key, and each received item is given to a function to compute a key, determining which handle receives the item. There is always default handle which receives an item if the result of the key function does not match any other handle.
Structs
DefaultHandle |
A |
KeyHandle |
A |
OwnerMCS |
A wrapper around a stream, that allows obtaining multiple handles for reading from that stream. |