Trait timely::dataflow::operators::core::rc::SharedStream

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

Convert a stream into a stream of shared containers

Required Methods

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

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