streamweave_timer/producers/
output.rs

1use super::interval_producer::IntervalProducer;
2use futures::Stream;
3use std::pin::Pin;
4use streamweave::Output;
5
6impl Output for IntervalProducer {
7  type Output = std::time::SystemTime;
8  type OutputStream = Pin<Box<dyn Stream<Item = std::time::SystemTime> + Send>>;
9}