AbstractDisposableAutoRelease |
Wraps lambda callbacks and when the upstream terminates or the observer gets disposed,
removes itself from a CompositeDisposable .
|
BasicFuseableObserver<T,R> |
Base class for a fuseable intermediate observer.
|
BasicIntQueueDisposable<T> |
An abstract QueueDisposable implementation, extending an AtomicInteger,
that defaults all unnecessary Queue methods to throw UnsupportedOperationException.
|
BasicQueueDisposable<T> |
An abstract QueueDisposable implementation that defaults all
unnecessary Queue methods to throw UnsupportedOperationException.
|
BiConsumerSingleObserver<T> |
|
BlockingBaseObserver<T> |
|
BlockingDisposableMultiObserver<T> |
Blocks until the upstream terminates and dispatches the outcome to
the actual observer.
|
BlockingFirstObserver<T> |
Blocks until the upstream signals its first value or completes.
|
BlockingLastObserver<T> |
Blocks until the upstream signals its last value or completes.
|
BlockingMultiObserver<T> |
A combined Observer that awaits the success or error signal via a CountDownLatch.
|
BlockingObserver<T> |
|
CallbackCompletableObserver |
|
ConsumerSingleObserver<T> |
|
DeferredScalarDisposable<T> |
Represents a fuseable container for a single value.
|
DeferredScalarObserver<T,R> |
A fuseable Observer that can generate 0 or 1 resulting value.
|
DisposableAutoReleaseMultiObserver<T> |
Wraps lambda callbacks and when the upstream terminates or this (Single | Maybe | Completable)
observer gets disposed, removes itself from a CompositeDisposable .
|
DisposableAutoReleaseObserver<T> |
Wraps lambda callbacks and when the upstream terminates or this observer gets disposed,
removes itself from a CompositeDisposable .
|
DisposableLambdaObserver<T> |
|
EmptyCompletableObserver |
|
ForEachWhileObserver<T> |
|
FutureMultiObserver<T> |
An Observer + Future that expects exactly one upstream value and provides it
via the (blocking) Future API.
|
FutureObserver<T> |
An Observer + Future that expects exactly one upstream value and provides it
via the (blocking) Future API.
|
InnerQueuedObserver<T> |
Subscriber that can fuse with the upstream and calls a support interface
whenever an event is available.
|
LambdaObserver<T> |
|
QueueDrainObserver<T,U,V> |
Abstract base class for subscribers that hold another subscriber, a queue
and requires queue-drain behavior.
|
QueueDrainSubscriberPad0 |
Pads the header away from other fields.
|
QueueDrainSubscriberPad2 |
Pads away the wip from the other fields.
|
QueueDrainSubscriberWip |
The wip counter.
|
ResumeSingleObserver<T> |
A SingleObserver implementation used for subscribing to the actual SingleSource
and replace the current Disposable in a parent AtomicReference.
|
SafeCompletableObserver |
Wraps another CompletableObserver and catches exceptions thrown by its
onSubscribe , onError or
onComplete methods despite the protocol forbids it.
|
SafeMaybeObserver<T> |
Wraps another MaybeObserver and catches exceptions thrown by its
onSubscribe , onSuccess , onError or
onComplete methods despite the protocol forbids it.
|
SafeSingleObserver<T> |
Wraps another SingleObserver and catches exceptions thrown by its
onSubscribe , onSuccess or onError methods despite
the protocol forbids it.
|