Использование задержки на массиве вызовов с Forkjoin

Question

Мне нужно установить задержку между выборками и соединить их вместе в конечном объекте.

ObservablesArr состоит из нескольких динамических вызовов, но иногда они достигают 100+, поэтому мне нужно, чтобы кто-то задушил их.

Я пробовал .pipe (задержка (50)), но, похоже, это не сдерживает, любые предложения приветствуются.

Примечание: Если я установлю тайм-аут на .next и .complete, он, похоже, зависнет.

Привет,

Брэй

Observable.forkJoin(observablesArr).subscribe((history: MarkerData[]): void => {
            const live: MarkerData[] = this.markersLiveService.fetch(macAddress, timeStart, timeEnd);
            let returnArray = [];
            for (let i: number = 0; i < history.length; i++) {
                if (history[i]) {
                    returnArray = returnArray.concat(history[i])
                }
            }
            subscribe.next([...returnArray, ...live]);
            subscribe.complete();
        });