Projects each source value to the same Observable which is flattened multiple times with switchMap in the output Observable.

switchMapTo<T, I, R>(innerObservable: ObservableInput<I>, resultSelector?: (outerValue: T, innerValue: I, outerIndex: number, innerIndex: number) => R): OperatorFunction<T, I | R>

Parameters

innerObservable	An Observable to replace each value from the source Observable.
resultSelector	Optional. Default is undefined. Type: (outerValue: T, innerValue: I, outerIndex: number, innerIndex: number) => R.

Returns

OperatorFunction<T, I | R>: An Observable that emits items from the given innerObservable (and optionally transformed through the deprecated resultSelector) every time a value is emitted on the source Observable, and taking only the values from the most recently projected inner Observable.

Description

It's like switchMap, but maps each value always to the same inner Observable.

Maps each source value to the given Observable innerObservable regardless of the source value, and then flattens those resulting Observables into one single Observable, which is the output Observable. The output Observables emits values only from the most recently emitted instance of innerObservable.

Example

Rerun an interval Observable on every click event

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

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

Overloads

switchMapTo(observable: ObservableInput<R>): OperatorFunction<any, R>

Parameters

observable

Type: ObservableInput.

Returns

OperatorFunction<any, R>

switchMapTo(observable: ObservableInput<R>, resultSelector: undefined): OperatorFunction<T, R>

Parameters

observable	Type: ObservableInput.
resultSelector	Type: undefined.

Returns

OperatorFunction<T, R>

switchMapTo(observable: ObservableInput<I>, resultSelector: (outerValue: T, innerValue: I, outerIndex: number, innerIndex: number) => R): OperatorFunction<T, R>

Parameters

observable	Type: ObservableInput.
resultSelector	Type: (outerValue: T, innerValue: I, outerIndex: number, innerIndex: number) => R.

Returns

OperatorFunction<T, R>

See Also

• concatMapTo
• switchAll
• switchMap
• mergeMapTo