Class CombineLatestAllOperator

Namespace

RxSharp.Operators

Assembly

RxSharp.dll

Extension methods implementing the combineLatestAll operator.

public static class CombineLatestAllOperator

Inheritance

System.Object

CombineLatestAllOperator

Methods

CombineLatestAll<T>(Observable<Observable<T>>)

Collects every inner observable produced by source and, once source completes, combines all of them with CombineLatest<T>(params Observable<T>[]): every time any collected inner observable emits (once every one of them has emitted at least once), the output emits a list of the latest values from each. Ported from rxjs's joinAllInternals applied to combineLatest: source.ToArray().MergeMap(sources => CombineLatest(sources)).

public static Observable<IReadOnlyList<T>> CombineLatestAll<T>(this Observable<Observable<T>> source)

Parameters

source Observable<Observable<T>>

The higher-order source sequence.

Returns

Observable<IReadOnlyList<T>>

An observable that emits a list of the latest values from every collected inner observable, updated as they emit.

Type Parameters

T

The type of values emitted by the inner observables.

Remarks

Same-type-only, like CombineLatest<T>(params Observable<T>[]) itself: this does not port rxjs's optional project parameter (a heterogeneous-arity result selector), which has no clean C# equivalent for the same reason Zip/ForkJoin/CombineLatest stayed same-type-array-only. Apply .Map(...) to the result instead if a projection is needed.