我实现了这个功能,每次迭代我都有7个请求发送每次environment.dashboard.frequency,但在开始时,我看到我向服务器发送了14个请求,而不是7个:
let requests: Observable<ResourceResponse>[] = initRequests(this.durationService.resourceDataDuration)
timer(0, environment.dashboard.frequency)
.pipe(
takeUntil(this.destroy),
startWith(0),
switchMap(() => forkJoin(requests))
)
.subscribe((responsesArr: ResourceResponse[]) => {
this.updateBegin()
for (const response of responsesArr) {
this.durationService.resourceDurationHandler.setPresentedDataRanges(
response,
this.durationService.resourceDataDuration,
this.durationService.resourcePresnetedDataDurations
)
this.updateMany(response.Resource, response.Response, true)
}
this.updateEnd()
requests = initRequests(this.durationService.resourceDataDuration)
})发布于 2020-08-24 21:58:00
timer(0, environment.dashboard.frequency) -> dueTime = 0 ->不需要startWith
https://stackoverflow.com/questions/63561907
复制相似问题