this.producers = [];
this.eiSvc.getProducerIds().pipe(
- mergeMap(prodIds =>
+ mergeMap(prodIds =>
forkJoin(prodIds.map(id => {
return forkJoin([
of(id),
this.eiSvc.getProducerStatus(id)
])
})
- )),
+ )),
finalize(() => this.loadingSubject.next(false))
).subscribe(result => {
this.producers = result.map(producer => {