Skip to content

Commit 0817e5e

Browse files
committed
Fix timer
1 parent c497979 commit 0817e5e

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

x-pack/plugins/task_manager/server/polling/observable_monitor.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ export function createObservableMonitor<T, E>(
3939
return new Observable((subscriber) => {
4040
const subscription: Subscription = interval(heartbeatInterval)
4141
.pipe(
42-
startWith(0),
42+
startWith(timer(0, heartbeatInterval)),
4343
// switch from the heartbeat interval to the instantiated observable until it completes / errors
4444
exhaustMap(() => takeUntilDurationOfInactivity(observableFactory(), inactivityTimeout)),
4545
// if an error is thrown, catch it, notify and try to recover

0 commit comments

Comments
 (0)