Searched refs:run_stats_reducer (Results 1 – 1 of 1) sorted by relevance
101 tokio::spawn(run_stats_reducer(rx)); in new()117 tokio::spawn(run_stats_reducer(rx)); in with_time_gen()173 async fn run_stats_reducer(mut rx: mpsc::Receiver<Message>) { in run_stats_reducer() function