added async stream

Smoren · Apr 20, 2023 · a9a6686 · a9a6686
1 parent 04b6ae0
commit a9a6686
Show file tree

Hide file tree

Showing 2 changed files with 433 additions and 0 deletions.
diff --git a/src/async-stream.ts b/src/async-stream.ts
@@ -33,6 +33,8 @@ import {
   zipLongestAsync,
 } from "./multi";
 import {
+  runningAverage,
+  runningAverageAsync,
   runningDifferenceAsync,
   runningMaxAsync,
   runningMinAsync,
@@ -423,6 +425,18 @@ export class AsyncStream {
     return this;
   }
 
+  /**
+   * Accumulate the running average (mean) over the stream.
+   *
+   * @param initialValue (Optional) If provided, the running average leads off with the initial value.
+   *
+   * @see math.runningAverageAsync
+   */
+  runningAverage(initialValue?: number): AsyncStream {
+    this.data = runningAverageAsync(this.data, initialValue);
+    return this;
+  }
+
   /**
    * Accumulate the running difference over the stream.
    *