Struct tamar::KeyedDataStream
source · pub struct KeyedDataStream<V, KS, K>where
KS: Fn(&Event<V>) -> K,{ /* private fields */ }
Implementations§
source§impl<V, KS, K> KeyedDataStream<V, KS, K>where
V: Send + Sync + 'static,
KS: Fn(&Event<V>) -> K + Send + 'static,
K: Hash + Eq + Send + Clone + 'static,
impl<V, KS, K> KeyedDataStream<V, KS, K>where V: Send + Sync + 'static, KS: Fn(&Event<V>) -> K + Send + 'static, K: Hash + Eq + Send + Clone + 'static,
pub fn add_sink<S>(self, sink: S)where S: Sink<V> + Send + 'static,
pub fn map<VO, FN, F>(self, map: FN) -> DataStream<VO>where VO: Send + 'static, FN: Fn(K, 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> AsyncDoubleArgFn<K, &'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(K, Event<V>, Sender<VO>) -> F + Send + Sync + 'static, F: Future<Output = ()> + Send + 'static,
pub fn process_state<VO, FN, F, GST, KSTF, KST>( self, process: FN, global_state: GST, key_state_fn: KSTF ) -> DataStream<VO>where VO: Send + 'static, FN: Fn(K, Event<V>, GST, KST, Sender<VO>) -> F + Send + Sync + 'static, F: Future<Output = ()> + Send + 'static, GST: Clone + Send + Sync + 'static, KSTF: Fn(&K) -> KST + Send + Sync + 'static, KST: Clone + Send + Sync + 'static,
pub fn window<WF>(self, factory: WF) -> WindowedDataStream<V, KS, WF>
Auto Trait Implementations§
impl<V, KS, K> !RefUnwindSafe for KeyedDataStream<V, KS, K>
impl<V, KS, K> !Send for KeyedDataStream<V, KS, K>
impl<V, KS, K> !Sync for KeyedDataStream<V, KS, K>
impl<V, KS, K> Unpin for KeyedDataStream<V, KS, K>where KS: Unpin,
impl<V, KS, K> !UnwindSafe for KeyedDataStream<V, KS, K>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more