in netbench-collector/src/generic.rs [55:69]
fn collect(mut proc: Proc, interval: Duration, is_open: Arc<AtomicBool>) {
let mut stats = Stats::default();
loop {
proc.load(&mut stats);
stats.print().unwrap();
if !is_open.load(Ordering::Relaxed) {
return;
}
std::thread::sleep(interval);
stats.time += interval;
}
}