streamweave_transformers/zip/
input.rs

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