streamweave_transformers/split-at/
output.rs

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