streamweave_transformers/split/
input.rs

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