Skip to content

Commit

Permalink
fix(ui): spawninfo polling wait for request end (#5855)
Browse files Browse the repository at this point in the history
  • Loading branch information
richardlt authored Jun 22, 2021
1 parent 266b47c commit 8849693
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ import { ProjectState } from 'app/store/project.state';
import { WorkflowState } from 'app/store/workflow.state';
import * as moment from 'moment';
import { from, interval, Subject, Subscription } from 'rxjs';
import { delay, mergeMap, retryWhen } from 'rxjs/operators';
import { delay, concatMap, retryWhen } from 'rxjs/operators';
import { webSocket, WebSocketSubject } from 'rxjs/webSocket';
import { WorkflowRunJobVariableComponent } from '../variables/job.variables.component';

Expand Down Expand Up @@ -104,13 +104,13 @@ export class WorkflowRunJobComponent implements OnInit, OnDestroy {
) {
this.subjectChannel = new Subject<WorkflowNodeJobRun>();
this.subscriptionChannel = this.subjectChannel.pipe(
mergeMap(data => from(this.onNodeJobRunChange(data)))
concatMap(data => from(this.onNodeJobRunChange(data)))
).subscribe();
}

ngOnInit(): void {
this.pollingSpawnInfoSubscription = interval(2000)
.pipe(mergeMap(_ => from(this.loadSpawnInfo())))
.pipe(concatMap(_ => from(this.loadSpawnInfo())))
.subscribe();
}

Expand Down

0 comments on commit 8849693

Please sign in to comment.