in streamstats/src/lib.rs [262:286]
fn basic_atomic() {
let mut streamstats = AtomicStreamstats::<AtomicU64>::new(1000);
assert_eq!(streamstats.percentile(0.0), Err(StreamstatsError::Empty));
streamstats.insert(1);
assert_eq!(streamstats.percentile(0.0), Ok(1));
streamstats.clear();
assert_eq!(streamstats.percentile(0.0), Err(StreamstatsError::Empty));
for i in 0..=10_000 {
streamstats.insert(i);
assert_eq!(streamstats.percentile(100.0), Ok(i));
}
let mut streamstats = AtomicStreamstats::<AtomicU64>::new(1000);
assert_eq!(streamstats.percentile(0.0), Err(StreamstatsError::Empty));
streamstats.insert(1);
assert_eq!(streamstats.percentile(0.0), Ok(1));
streamstats.clear();
assert_eq!(streamstats.percentile(0.0), Err(StreamstatsError::Empty));
for i in 0..=10_000 {
streamstats.insert(i);
assert_eq!(streamstats.percentile(100.0), Ok(i));
}
}