More tests

tremor-rs · May 2, 2022 · 7bfe92c · 7bfe92c
1 parent a666edf
commit 7bfe92c
Showing 1 changed file with 18 additions and 0 deletions.
diff --git a/tremor-script/src/std_lib/win.rs b/tremor-script/src/std_lib/win.rs
@@ -278,6 +278,24 @@ mod test {
         Ok(())
     }
 
+    #[test]
+    fn first_merge() -> Result<()> {
+        let mut a = First::default();
+        let mut b = First::default();
+        a.init();
+        b.init();
+
+        a.accumulate(&[&Value::from(1)])?;
+        a.accumulate(&[&Value::from(2)])?;
+        b.accumulate(&[&Value::from(3)])?;
+
+        a.merge(&b)?;
+
+        assert_eq!(Value::from(1), a.emit().unwrap());
+
+        Ok(())
+    }
+
     #[test]
     fn cardinality() {
         let f = fun("win", "cardinality");