Class ExhaustAllOperator
Extension methods implementing the exhaustAll operator.
public static class ExhaustAllOperator
- Inheritance
-
System.ObjectExhaustAllOperator
Methods
ExhaustAll<T>(Observable<Observable<T>>)
Converts a higher-order observable (an observable of observables) into a first-order observable by
subscribing to an inner observable and ignoring every other inner observable produced while it is still
active. Equivalent to source.ExhaustMap(x => x).
public static Observable<T> ExhaustAll<T>(this Observable<Observable<T>> source)
Parameters
sourceObservable<Observable<T>>The higher-order source sequence.
Returns
- Observable<T>
An observable that emits the values of each accepted inner observable, ignoring inner observables produced while one is still active.
Type Parameters
TThe type of values emitted by the inner observables.