Struct tamar::WindowedDataStream
source · pub struct WindowedDataStream<VI, KS, WF> { /* private fields */ }
Implementations§
source§impl<VI, KS, K, WF> WindowedDataStream<VI, KS, WF>where
VI: Send + Sync + 'static,
KS: Fn(&Event<VI>) -> K + Send + Sync + 'static,
K: Hash + Eq + Send + Sync + Clone + 'static,
WF: WindowFactory + Send + 'static,
impl<VI, KS, K, WF> WindowedDataStream<VI, KS, WF>where VI: Send + Sync + 'static, KS: Fn(&Event<VI>) -> K + Send + Sync + 'static, K: Hash + Eq + Send + Sync + Clone + 'static, WF: WindowFactory + Send + 'static,
pub fn process<VO, FN, F>(self, process: FN) -> DataStream<VO>where VO: Send + 'static, FN: Fn(K, Box<[Event<VI>]>, Sender<VO>) -> F + Send + Sync + 'static, F: Future<Output = ()> + Send + 'static, WF::Processor<VI>: Send,
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, Box<[Event<VI>]>, 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, WF::Processor<VI>: Send,
pub fn aggregate<VO, ACC>(self, accumulator: ACC) -> DataStream<VO>where VO: Add<Output = VO> + Send + 'static, ACC: Fn(VI) -> VO + Send + Sync + 'static, WF::Aggregator<VO>: Send,
Auto Trait Implementations§
impl<VI, KS, WF> !RefUnwindSafe for WindowedDataStream<VI, KS, WF>
impl<VI, KS, WF> !Send for WindowedDataStream<VI, KS, WF>
impl<VI, KS, WF> !Sync for WindowedDataStream<VI, KS, WF>
impl<VI, KS, WF> Unpin for WindowedDataStream<VI, KS, WF>where KS: Unpin, WF: Unpin,
impl<VI, KS, WF> !UnwindSafe for WindowedDataStream<VI, KS, WF>
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