Package rx.internal.operators

Class CompletableOnSubscribeMerge

java.lang.Object

rx.internal.operators.CompletableOnSubscribeMerge

All Implemented Interfaces:

Completable.CompletableOnSubscribe, Action, Action1<Completable.CompletableSubscriber>, Function

public final class CompletableOnSubscribeMerge
extends Object
implements Completable.CompletableOnSubscribe

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	CompletableOnSubscribeMerge.CompletableMergeSubscriber

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final boolean	delayErrors
(package private) final int	maxConcurrency
(package private) final Observable<Completable>	source

Constructor Summary

Constructors

Constructor	Description
CompletableOnSubscribeMerge(Observable<? extends Completable> source, int maxConcurrency, boolean delayErrors)

Method Summary

Modifier and Type	Method	Description
void	call(Completable.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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

source

final Observable<Completable> source

maxConcurrency

final int maxConcurrency

delayErrors

final boolean delayErrors

Constructor Details

CompletableOnSubscribeMerge

public CompletableOnSubscribeMerge(Observable<? extends Completable> source,
 int maxConcurrency,
 boolean delayErrors)

Method Details

call

public void call(Completable.CompletableSubscriber s)

Specified by:

call in interface Action1<Completable.CompletableSubscriber>

collectErrors

public static Throwable collectErrors(Queue<Throwable> q)

Collects the Throwables from the queue, adding subsequent Throwables as suppressed to the first Throwable and returns it.

Parameters:

q - the queue to drain

Returns:

the Throwable containing all other Throwables as suppressed