Class MergeMapToOperator

Namespace

RxSharp.Operators

Assembly

RxSharp.dll

Extension methods implementing the mergeMapTo operator.

public static class MergeMapToOperator

Inheritance

System.Object

MergeMapToOperator

Methods

MergeMapTo<TSource, TResult>(Observable<TSource>, Observable<TResult>)

Projects every value from source to the same innerObservable, regardless of the source value, merging every resulting subscription's emissions into the output with unbounded concurrency. Equivalent to source.MergeMap(_ => innerObservable).

public static Observable<TResult> MergeMapTo<TSource, TResult>(this Observable<TSource> source, Observable<TResult> innerObservable)

Parameters

source Observable<TSource>

The source sequence.

innerObservable Observable<TResult>

The observable to subscribe to for every value emitted by source.

Returns

Observable<TResult>

An observable that merges the values of every subscription to innerObservable.

Type Parameters

TSource

The type of values emitted by source.

TResult

The type of values emitted by innerObservable.

Remarks

Marked @deprecated upstream (in favor of mergeMap(() => result)) but still present in rxjs 7.8.2, so it is ported here too. Like MergeMapOperator, this does not port rxjs's deprecated resultSelector/concurrent parameters — apply .Map(...) to the result for a projection.