Function multi_consumer_stream::mcs

pub fn mcs<S: Stream, K: Copy + Eq + Hash, F: Fn(&S::Item) -> K>(
    stream: S, 
    key_fn: F
) -> MCS<S, K, F>

Create a new MCS, wrapping the given stream.