streamweave_vec/producers/
output.rs1use super::vec_producer::VecProducer;
2use futures::Stream;
3use std::pin::Pin;
4use streamweave::Output;
5
6impl<T: std::fmt::Debug + Clone + Send + Sync + 'static> Output for VecProducer<T> {
7 type Output = T;
8 type OutputStream = Pin<Box<dyn Stream<Item = T> + Send>>;
9}