public final class CompletableOnSubscribeMerge extends Object implements Completable.OnSubscribe
Constructor and Description |
---|
CompletableOnSubscribeMerge(Observable<? extends Completable> source,
int maxConcurrency,
boolean delayErrors) |
Modifier and Type | Method and Description |
---|---|
void |
call(CompletableSubscriber s) |
static Throwable |
collectErrors(Queue<Throwable> q)
Collects the Throwables from the queue, adding subsequent Throwables as suppressed to
the first Throwable and returns it.
|
public CompletableOnSubscribeMerge(Observable<? extends Completable> source, int maxConcurrency, boolean delayErrors)
public void call(CompletableSubscriber s)
call
in interface Action1<CompletableSubscriber>
Copyright © 2017. All rights reserved.