Fix merge scan

elastic · Sep 30, 2020 · 9f6a53b · 9f6a53b
1 parent 17c4435
commit 9f6a53b
Showing 1 changed file with 5 additions and 7 deletions.
diff --git a/x-pack/plugins/task_manager/server/lib/create_managed_configuration.ts b/x-pack/plugins/task_manager/server/lib/create_managed_configuration.ts
@@ -124,13 +124,11 @@ function countErrors(errors$: Observable<Error>, countInterval: number): Observa
   ).pipe(
     // When tag is "flush", reset the error counter
     // Otherwise increment the error counter
-    mergeScan(
-      ({ count }, next) =>
-        next === FLUSH_MARKER
-          ? of(emitErrorCount(count), resetErrorCount())
-          : of(incementErrorCount(count)),
-      emitErrorCount(0)
-    ),
+    mergeScan(({ count }, next) => {
+      return next === FLUSH_MARKER
+        ? of(emitErrorCount(count), resetErrorCount())
+        : of(incementErrorCount(count));
+    }, emitErrorCount(0)),
     filter(isEmitEvent),
     map(({ count }) => count)
   );