Fix timer

mikecote · Sep 29, 2020 · 0817e5e · 0817e5e
1 parent c497979
commit 0817e5e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/x-pack/plugins/task_manager/server/polling/observable_monitor.ts b/x-pack/plugins/task_manager/server/polling/observable_monitor.ts
@@ -39,7 +39,7 @@ export function createObservableMonitor<T, E>(
   return new Observable((subscriber) => {
     const subscription: Subscription = interval(heartbeatInterval)
       .pipe(
-        startWith(0),
+        startWith(timer(0, heartbeatInterval)),
         // switch from the heartbeat interval to the instantiated observable until it completes / errors
         exhaustMap(() => takeUntilDurationOfInactivity(observableFactory(), inactivityTimeout)),
         // if an error is thrown, catch it, notify and try to recover