通過在先前內(nèi)部 Observable 尚未完成之前刪除內(nèi)部 Observable，將高階 Observable 轉(zhuǎn)換為一階 Observable。

exhaust<T>(): OperatorFunction<any, T>

參量

沒有參數(shù)。

returns

OperatorFunction<any, T>：一個 Observable，它獲取 Observable 的源，并專門傳播第一個 Observable，直到它完成，然后訂閱下一個 Observable。

描述

在當前內(nèi)部 Observable 仍在執(zhí)行時，通過刪除下一個內(nèi)部 Observable 來展平 Observable-of-Observables。

exhaust訂閱發(fā)出 Observable 的 Observable，也稱為高階 Observable。每次觀察到這些內(nèi)部可觀察對象發(fā)射的一個時，輸出 Observable 便開始發(fā)射該內(nèi)部可觀察對象發(fā)射的項目。到目前為止，它的行為類似于mergeAll。但是，exhaust如果先前的 Observable 尚未完成，則 忽略每個新的內(nèi)部 Observable。完成后，它將接受并展平下一個內(nèi)部 Observable，并重復此過程。

例

僅當當前沒有活動的計時器時，才為每次點擊運行一個有限的計時器

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


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

也可以看看

• combineAll
• concatAll
• switchAll
• switchMap
• mergeAll
• exhaustMap
• zipAll