streamweave_transformers/limit/
input.rs

1use super::limit_transformer::LimitTransformer;
2use futures::Stream;
3use std::pin::Pin;
4use streamweave::Input;
5
6impl<T> Input for LimitTransformer<T>
7where
8  T: std::fmt::Debug + Clone + Send + Sync + 'static,
9{
10  type Input = T;
11  type InputStream = Pin<Box<dyn Stream<Item = T> + Send>>;
12}