streamweave_transformers/map/
input.rs

1use super::map_transformer::MapTransformer;
2use futures::Stream;
3use std::pin::Pin;
4use streamweave::Input;
5
6impl<F, I, O> Input for MapTransformer<F, I, O>
7where
8  F: FnMut(I) -> O + Send + Clone + 'static,
9  I: std::fmt::Debug + Clone + Send + Sync + 'static,
10  O: std::fmt::Debug + Clone + Send + Sync + 'static,
11{
12  type Input = I;
13  type InputStream = Pin<Box<dyn Stream<Item = I> + Send>>;
14}