Struct tamar::DataStream

pub struct DataStream<V> { /* private fields */ }

Implementations

impl<V> DataStream<V>where V: Send + Sync + 'static,

pub fn add_sink<S>(self, sink: S)where S: Sink<V> + 'static,

pub fn map<VO, FN, F>(self, map: FN) -> DataStream<VO>where VO: Send + 'static, FN: Fn(Event<V>) -> F + Send + Sync + 'static, F: Future<Output = Event<VO>> + Send + 'static,

pub fn filter<FN>(self, filter: FN) -> DataStream<V>where FN: for<'a> AsyncSingleArgFn<&'a Event<V>, Output = bool> + Send + Sync + 'static,

pub fn process<VO, FN, F>(self, process: FN) -> DataStream<VO>where VO: Send + 'static, FN: Fn(Event<V>, Sender<VO>) -> F + Send + Sync + 'static, F: Future<Output = ()> + Send + 'static,

pub fn process_state<VO, FN, F, GST>( self, process: FN, global_state: GST ) -> DataStream<VO>where VO: Send + 'static, FN: Fn(Event<V>, GST, Sender<VO>) -> F + Send + Sync + 'static, F: Future<Output = ()> + Send + 'static, GST: Clone + Send + Sync + 'static,

pub fn key_by<KS, K>(self, selector: KS) -> KeyedDataStream<V, KS, K>where KS: Fn(&Event<V>) -> K, K: Hash + Eq + Send + Clone + 'static,

impl<V> DataStream<V>where V: Send + Sync + Clone + 'static,

pub fn split(self) -> (Self, Self)