streamweave_stdio/consumers/
input.rs

1use super::{stderr_consumer::StderrConsumer, stdout_consumer::StdoutConsumer};
2use streamweave::Input;
3
4impl<T> Input for StdoutConsumer<T>
5where
6  T: std::fmt::Debug + Clone + Send + Sync + std::fmt::Display + 'static,
7{
8  type Input = T;
9  type InputStream = futures::stream::BoxStream<'static, T>;
10}
11
12impl<T> Input for StderrConsumer<T>
13where
14  T: std::fmt::Debug + Clone + Send + Sync + std::fmt::Display + 'static,
15{
16  type Input = T;
17  type InputStream = futures::stream::BoxStream<'static, T>;
18}