RxJS exhaustMap

將每個(gè)源值投影到一個(gè) Observable，只有在先前的可預(yù)測 Observable 完成時(shí)，該值才合并到 Observable 輸出中。

exhaustMap<T, R, O extends ObservableInput<any>>(project: (value: T, index: number) => O, resultSelector?: (outerValue: T, innerValue: ObservedValueOf<O>, outerIndex: number, innerIndex: number) => R): OperatorFunction<T, ObservedValueOf<O> | R>

參量

returns

OperatorFunction<T, ObservedValueOf<O> | R>：一個(gè) Observable，其中包含源中每個(gè)項(xiàng)目的預(yù)計(jì)可觀測值，而忽略在其先前的 Observable 完成之前開始的預(yù)計(jì)可觀測值。

描述

將每個(gè)值映射到一個(gè) Observable，然后使用展平所有這些內(nèi)部 Observable exhaust。

返回一個(gè) Observable，它基于將您提供的函數(shù)應(yīng)用于源 Observable 發(fā)出的每個(gè)項(xiàng)目而發(fā)出項(xiàng)目，其中該函數(shù)返回一個(gè)（所謂的“內(nèi)部”）Observable。當(dāng)將源值投影到 Observable 時(shí)，輸出 Observable 開始發(fā)出該投影的 Observable 發(fā)出的項(xiàng)目。但是，exhaustMap如果先前的可觀測值尚未完成，則忽略每個(gè)新的可觀測值。完成后，它將接受并展平下一個(gè)預(yù)計(jì)的 Observable，并重復(fù)此過程。

例

僅當(dāng)當(dāng)前沒有活動(dòng)的計(jì)時(shí)器時(shí)，才為每次點(diǎn)擊運(yùn)行一個(gè)有限的計(jì)時(shí)器

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


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

超載

exhaustMap(project: (value: T, index: number) => O): OperatorFunction<T, ObservedValueOf<O>>

returnsOperatorFunction<T, ObservedValueOf<O>>

exhaustMap(project: (value: T, index: number) => O, resultSelector: undefined): OperatorFunction<T, ObservedValueOf<O>>

returnsOperatorFunction<T, ObservedValueOf<O>>

exhaustMap(project: (value: T, index: number) => any, resultSelector: (outerValue: T, innerValue: I, outerIndex: number, innerIndex: number) => R): OperatorFunction<T, R>

returnsOperatorFunction<T, R>

也可以看看

• concatMap
• exhaust
• mergeMap
• switchMap