Package io.reactivex.rxjava3.internal.observers

Interface Summary

Interface	Description
InnerQueuedObserverSupport<T>	Interface to allow the InnerQueuedSubscriber to call back a parent with signals.

Class Summary

Class	Description
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.