pub fn run_channel( generator: impl Stage1, tx_s1: Sender<SeededData<TimePoint>>, stats: Arc<Stats>, ) -> Result<(), Box<dyn Error>>
Generate data and send them progressively to a channel