RxJS concatMapTo

將每個(gè)源值投影到相同的 Observable，將其合并為多個(gè) 在輸出 Observable 上以序列化的方式排列次。

concatMapTo<T, R, O extends ObservableInput<any>>(innerObservable: O, resultSelector?: (outerValue: T, innerValue: ObservedValueOf<O>, outerIndex: number, innerIndex: number) => R): OperatorFunction<T, ObservedValueOf<O> | R>

參量

returns

OperatorFunction<T, ObservedValueOf<O> | R>：通過加入 對(duì)于每個(gè)發(fā)射的值，一個(gè)接一個(gè)地通過觀察 從源頭上

描述

就像 concatMap，但是映射每個(gè)值 始終在同一個(gè)內(nèi)部 Observable 中。

映射的每個(gè)源值給定的可觀測(cè) innerObservable無論 源值的一半，然后將那些所得的 Observables 統(tǒng)一為一個(gè) single Observable，這是輸出 Observable。 每個(gè)新 innerObservable 在輸出 Observable 上發(fā)出的實(shí)例與前一個(gè)串聯(lián) innerObservable實(shí)例。

警告： 如果源值無休止地到達(dá)并且比它們更快地到達(dá) 相應(yīng)的內(nèi)部 Observables 可以完成，這將導(dǎo)致內(nèi)存問題 當(dāng)內(nèi)部 Observable 聚集在一個(gè)無界緩沖區(qū)中時(shí)，它們等待轉(zhuǎn)向 被訂閱。

注意： concatMapTo等效于 mergeMapTo并發(fā)參數(shù) 設(shè)置為 1。

例

對(duì)于每個(gè)單擊事件，請(qǐng)從0到3每秒進(jìn)行一次滴答，無需并發(fā)

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


const clicks = fromEvent(document, 'click');
const result = clicks.pipe(
  concatMapTo(interval(1000).pipe(take(4))),
);
result.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

超載

concatMapTo(observable: O): OperatorFunction<T, ObservedValueOf<O>>

returns OperatorFunction<T, ObservedValueOf<O>>

concatMapTo(observable: O, resultSelector: undefined): OperatorFunction<T, ObservedValueOf<O>>

returns OperatorFunction<T, ObservedValueOf<O>>

concatMapTo(observable: O, resultSelector: (outerValue: T, innerValue: ObservedValueOf<O>, outerIndex: number, innerIndex: number) => R): OperatorFunction<T, R>

returns OperatorFunction<T, R>

也可以看看

• concat
• concatAll
• concatMap

• mergeMapTo

• switchMapTo