Calculate P-Value for Chi Square

Cargo.toml

@@ -25,6 +25,7 @@ futures-util = "0.3.31"
 miette = { version = "7", features = ["fancy"] }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
+statrs = "0.17.1"
 thiserror = "1.0.61"
 tokio = { version = "1.37.0", features = ["full"] }
 tokio-stream = { version = "0.1", features = ["time"] }

src/pipeline/mod.rs

@@ -42,7 +42,7 @@ pub fn repeat_query<T: Observer>(
         //   be moved between iterations.
         pin!(timer);
         // Each iteration of the loop represents one unit of tiem.
-        while let Some(_) = timer.next().await {
+        while timer.next().await.is_some() {
             // • We perform the query then dump the results into the stream.
             let items = observer.query().await;
             for item in items {