streamweave_transformers/reduce/input.rs
1use super::reduce_transformer::ReduceTransformer;
2use futures::Stream;
3use std::pin::Pin;
4use streamweave::Input;
5
6impl<T, Acc, F> Input for ReduceTransformer<T, Acc, F>
7where
8 T: std::fmt::Debug + Clone + Send + Sync + 'static,
9 Acc: std::fmt::Debug + Clone + Send + Sync + 'static,
10 F: FnMut(Acc, T) -> Acc + Send + Clone + 'static,
11{
12 type Input = T;
13 type InputStream = Pin<Box<dyn Stream<Item = T> + Send>>;
14}