pub trait SharedStream<S: Scope, C: Container> {
    // Required method
    fn shared(&self) -> StreamCore<S, Rc<C>>;
}
Expand description

Convert a stream into a stream of shared containers

Required Methods§

source

fn shared(&self) -> StreamCore<S, Rc<C>>

Convert a stream into a stream of shared data

Examples
use timely::dataflow::operators::{ToStream, Inspect};
use timely::dataflow::operators::rc::SharedStream;

timely::example(|scope| {
    (0..10).to_stream(scope)
           .shared()
           .inspect(|x| println!("seen: {:?}", x));
});

Implementors§

source§

impl<S: Scope, C: Container> SharedStream<S, C> for StreamCore<S, C>