Interface | Description |
---|---|
InnerQueuedObserverSupport<T> |
Interface to allow the InnerQueuedSubscriber to call back a parent
with signals.
|
Class | Description |
---|---|
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> | |
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.
|
DisposableLambdaObserver<T> | |
EmptyCompletableObserver | |
ForEachWhileObserver<T> | |
FutureObserver<T> |
An Observer + Future that expects exactly one upstream value and provides it
via the (blocking) Future API.
|
FutureSingleObserver<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.
|
ResumeSingleObserver<T> |
A SingleObserver implementation used for subscribing to the actual SingleSource
and replace the current Disposable in a parent AtomicReference.
|
SubscriberCompletableObserver<T> |
Copyright © 2018 JBoss by Red Hat. All rights reserved.