Class ZipAllOperator

Namespace

RxSharp.Operators

Assembly

RxSharp.dll

Extension methods implementing the zipAll operator.

public static class ZipAllOperator

Inheritance

System.Object

ZipAllOperator

Methods

ZipAll<T>(Observable<Observable<T>>)

Collects every inner observable produced by source and, once source completes, combines all of them with Zip<T>(params Observable<T>[]): the Nth value from every collected inner observable is combined into a single emitted list, positionally. Ported from rxjs's joinAllInternals applied to zip: source.ToArray().MergeMap(sources => Zip(sources)).

public static Observable<IReadOnlyList<T>> ZipAll<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 Nth value from every collected inner observable, in order.

Type Parameters

T

The type of values emitted by the inner observables.

Remarks

Same-type-only, like Zip<T>(params Observable<T>[]) itself — see CombineLatestAll<T>(Observable<Observable<T>>)'s remarks for why no project parameter is ported.