ExhaustAllOperator<T> extension

on

• Observable<Observable<T>>

Methods

exhaustAll({int concurrent = 1}) → Observable<T>

Emits and completes higher-order Observable. Subscribes to at most concurrent sources, and drops observables exceeding this threshold.