public final class CompletableOnSubscribeMerge extends java.lang.Object implements Completable.CompletableOnSubscribe
| Constructor and Description |
|---|
CompletableOnSubscribeMerge(rx.Observable<? extends Completable> source,
int maxConcurrency,
boolean delayErrors) |
| Modifier and Type | Method and Description |
|---|---|
void |
call(Completable.CompletableSubscriber s) |
static java.lang.Throwable |
collectErrors(java.util.Queue<java.lang.Throwable> q)
Collects the Throwables from the queue, adding subsequent Throwables as suppressed to
the first Throwable and returns it.
|
public CompletableOnSubscribeMerge(rx.Observable<? extends Completable> source, int maxConcurrency, boolean delayErrors)
public void call(Completable.CompletableSubscriber s)
call in interface rx.functions.Action1<Completable.CompletableSubscriber>public static java.lang.Throwable collectErrors(java.util.Queue<java.lang.Throwable> q)
q - the queue to drain