Top Inners Fields Constructors Methods
rx.internal.operators

public final Class CompletableOnSubscribeMerge

extends Object
implements OnSubscribe
Class Inheritance
All Implemented Interfaces
rx.Completable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Imports
java.util.*, java.util.concurrent.ConcurrentLinkedQueue, java.util.concurrent.atomic.*, rx.*, .Completable.OnSubscribe, .Observable, rx.exceptions.CompositeException, rx.plugins.RxJavaHooks, rx.subscriptions.CompositeSubscription

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
CompletableOnSubscribeMerge.CompletableMergeSubscriber

Field Summary

Modifier and TypeField and Description
pack-priv final boolean
delayErrors

pack-priv final int
maxConcurrency

pack-priv final Observable<Completable>
source

Constructor Summary

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

Method Summary

Modifier and TypeMethod and Description
public void
call(CompletableSubscriber s)

Implements rx.functions.Action1.call.

public static Throwable

Returns:

the Throwable containing all other Throwables as suppressed
collectErrors(Queue<Throwable>
the queue to drain
q)

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

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

delayErrorsback to summary
pack-priv final boolean delayErrors
maxConcurrencyback to summary
pack-priv final int maxConcurrency
sourceback to summary
pack-priv final Observable<Completable> source

Constructor Detail

CompletableOnSubscribeMergeback to summary
public CompletableOnSubscribeMerge(Observable<? extends Completable> source, int maxConcurrency, boolean delayErrors)
Annotations
@SuppressWarnings:unchecked

Method Detail

callback to summary
public void call(CompletableSubscriber s)

Implements rx.functions.Action1.call.

Annotations
@Override
collectErrorsback to summary
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:Queue<Throwable>

the queue to drain

Returns:Throwable

the Throwable containing all other Throwables as suppressed

rx.internal.operators back to summary

pack-priv final Class CompletableOnSubscribeMerge.CompletableMergeSubscriber

extends Subscriber<Completable>
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv final CompletableSubscriber
actual

pack-priv final boolean
delayErrors

pack-priv volatile boolean
done

pack-priv final AtomicReference<Queue<Throwable>>
errors

pack-priv final AtomicBoolean
once

pack-priv final CompositeSubscription
set

pack-priv final AtomicInteger
wip

Constructor Summary

AccessConstructor and Description
public
CompletableMergeSubscriber(CompletableSubscriber actual, int maxConcurrency, boolean delayErrors)

Method Summary

Modifier and TypeMethod and Description
pack-priv Queue<Throwable>
getOrCreateErrors()

public void
onCompleted()

Implements rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.
public void
onError(Throwable
the exception encountered by the Observable
t)

Implements rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.
public void
onNext(Completable
the item emitted by the Observable
t)

Implements rx.Observer.onNext.

Provides the Observer with a new item to observe.
pack-priv void
terminate()

Inherited from rx.Subscriber:
addisUnsubscribedonStartrequestsetProducerunsubscribe

Field Detail

actualback to summary
pack-priv final CompletableSubscriber actual
delayErrorsback to summary
pack-priv final boolean delayErrors
doneback to summary
pack-priv volatile boolean done
errorsback to summary
pack-priv final AtomicReference<Queue<Throwable>> errors
onceback to summary
pack-priv final AtomicBoolean once
setback to summary
pack-priv final CompositeSubscription set
wipback to summary
pack-priv final AtomicInteger wip

Constructor Detail

CompletableMergeSubscriberback to summary
public CompletableMergeSubscriber(CompletableSubscriber actual, int maxConcurrency, boolean delayErrors)

Method Detail

getOrCreateErrorsback to summary
pack-priv Queue<Throwable> getOrCreateErrors()
onCompletedback to summary
public void onCompleted()

Implements rx.Observer.onCompleted.

Doc from rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.

The Observable will not call this method if it calls onError.

Annotations
@Override
onErrorback to summary
public void onError(Throwable t)

Implements rx.Observer.onError.

Doc from rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call onNext or onCompleted.

Parameters
t:Throwable

the exception encountered by the Observable

Annotations
@Override
onNextback to summary
public void onNext(Completable t)

Implements rx.Observer.onNext.

Doc from rx.Observer.onNext.

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either onCompleted or onError.

Parameters
t:Completable

the item emitted by the Observable

Annotations
@Override
terminateback to summary
pack-priv void terminate()