streamweave_tempfile/consumers/
input.rs

1use super::tempfile_consumer::TempFileConsumer;
2use futures::Stream;
3use std::pin::Pin;
4use streamweave::Input;
5
6impl Input for TempFileConsumer {
7  type Input = String;
8  type InputStream = Pin<Box<dyn Stream<Item = String> + Send>>;
9}