RxJS concatAll

將高階 Observable 轉換為的一階 Observable 將內部的 Observable 依次排列。

concatAll<T>(): OperatorFunction<ObservableInput<T>, T>

參量

沒有參數。

returns

OperatorFunction<ObservableInput<T>, T>：從所有內部可見的發(fā)射值 觀察值串聯(lián)在一起。

描述

通過放置一個可觀察的數來展平 內在可觀之后。

將源發(fā)出的每個 Observable（高階 Observable）加入 系列時尚。 它僅在 先前的內部 Observable 已完成，并將它們的所有值合并到 返回的可觀察值。

警告： 如果源 Observable 迅速發(fā)出 Observable，并且 無休止地發(fā)出，而內部的 Observables 發(fā)出的速度通常比 源發(fā)出，您可能會遇到內存問題，因為傳入的 Observable 收集在無界緩沖區(qū)中。

注意： concatAll等效于 mergeAll并發(fā)參數設置 到 1。

例

對于每個單擊事件，請從0到3每秒進行一次滴答，無需并發(fā)

import { fromEvent, interval } from 'rxjs';
import { map, take, concatAll } from 'rxjs/operators';


const clicks = fromEvent(document, 'click');
const higherOrder = clicks.pipe(
  map(ev => interval(1000).pipe(take(4))),
);
const firstOrder = higherOrder.pipe(concatAll());
firstOrder.subscribe(x => console.log(x));


// Results in the following:
// (results are not concurrent)
// For every click on the "document" it will emit values 0 to 3 spaced
// on a 1000ms interval
// one click = 1000ms-> 0 -1000ms-> 1 -1000ms-> 2 -1000ms-> 3

也可以看看

• combineAll
• concat
• concatMap
• concatMapTo
• exhaust
• mergeAll
• switchAll
• switchMap
• zipAll