Better coverage for aggregate functions

Signed-off-by: Heinz N. Gies <heinz@licenser.net>
tremor-rs · May 17, 2021 · 2afb18d · 2afb18d
1 parent c792eb9
commit 2afb18d
Show file tree

Hide file tree

Showing 3 changed files with 248 additions and 158 deletions.
diff --git a/tremor-script/src/registry.rs b/tremor-script/src/registry.rs
@@ -37,7 +37,7 @@ pub trait TremorAggrFn: DowncastSync + Sync + Send {
     ///
     /// # Errors
     /// if the function can not compensate the data
-    fn compensate<'event>(&mut self, args: &[&Value<'event>]) -> FResult<()>;
+    // fn compensate<'event>(&mut self, args: &[&Value<'event>]) -> FResult<()>;
     /// Emits the function
     ///
     /// # Errors
@@ -706,14 +706,14 @@ impl TremorAggrFnWrapper {
         self.fun.accumulate(args)
     }
 
-    /// Compensate for a value being removed
-    ///
-    /// # Errors
-    /// if compensating the function fails
-    #[cfg(not(tarpaulin_include))] // just a passthrough
-    pub fn compensate<'event>(&mut self, args: &[&Value<'event>]) -> FResult<()> {
-        self.fun.compensate(args)
-    }
+    // /// Compensate for a value being removed
+    // ///
+    // /// # Errors
+    // /// if compensating the function fails
+    // #[cfg(not(tarpaulin_include))] // just a passthrough
+    // pub fn compensate<'event>(&mut self, args: &[&Value<'event>]) -> FResult<()> {
+    //     self.fun.compensate(args)
+    // }
 
     /// Emits the function
     ///