From c876bb001f999e288410201b2306e8c3f3261836 Mon Sep 17 00:00:00 2001 From: metamuffin Date: Sun, 8 Jun 2025 13:02:49 +0200 Subject: optional stdev in delay module + fmt --- src/modules/delay.rs | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'src/modules/delay.rs') diff --git a/src/modules/delay.rs b/src/modules/delay.rs index 5b5ce06..31036fe 100644 --- a/src/modules/delay.rs +++ b/src/modules/delay.rs @@ -17,7 +17,7 @@ pub struct DelayKind; #[derive(Deserialize)] struct Delay { duration: u64, - stdev: u64, + stdev: Option, next: DynNode, } @@ -36,11 +36,12 @@ impl Node for Delay { request: NodeRequest, ) -> Pin> + Send + Sync + 'a>> { Box::pin(async move { - sleep(Duration::from_millis(if self.stdev == 0 { + let stdev = self.stdev.unwrap_or_default(); + sleep(Duration::from_millis(if stdev == 0 { self.duration } else { self.duration.saturating_add_signed( - rand_distr::Normal::new(0., self.stdev as f32) + rand_distr::Normal::new(0., stdev as f32) .unwrap() .sample(&mut rand::rng()) as i64, ) -- cgit v1.2.3-70-g09d2