github-mirrors/kibana
1
0
Fork 0
mirror of https://github.com/elastic/kibana.git synced 2025-04-24 17:59:23 -04:00
Code Issues Projects Releases Packages Wiki Activity

Fix timer

Browse source
This commit is contained in:
Mike Cote 2020-09-29 09:50:44 -04:00
parent c497979f3e
commit 0817e5e6a5
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
x-pack/plugins/task_manager/server/polling/observable_monitor.ts
View file

@ -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