Package io.reactivex.rxjava3.internal.observers
package io.reactivex.rxjava3.internal.observers
-
ClassDescriptionWraps lambda callbacks and when the upstream terminates or the observer gets disposed, removes itself from a
CompositeDisposable
.Base class for a fuseable intermediate observer.An abstract QueueDisposable implementation, extending an AtomicInteger, that defaults all unnecessary Queue methods to throw UnsupportedOperationException.An abstract QueueDisposable implementation that defaults all unnecessary Queue methods to throw UnsupportedOperationException.Blocks until the upstream terminates and dispatches the outcome to the actual observer.Blocks until the upstream signals its first value or completes.Blocks until the upstream signals its last value or completes.A combined Observer that awaits the success or error signal via a CountDownLatch.Represents a fuseable container for a single value.A fuseable Observer that can generate 0 or 1 resulting value.Wraps lambda callbacks and when the upstream terminates or this (Single | Maybe | Completable) observer gets disposed, removes itself from aCompositeDisposable
.Wraps lambda callbacks and when the upstream terminates or this observer gets disposed, removes itself from aCompositeDisposable
.An Observer + Future that expects exactly one upstream value and provides it via the (blocking) Future API.An Observer + Future that expects exactly one upstream value and provides it via the (blocking) Future API.Subscriber that can fuse with the upstream and calls a support interface whenever an event is available.Interface to allow the InnerQueuedSubscriber to call back a parent with signals.QueueDrainObserver<T,U, V> Abstract base class for subscribers that hold another subscriber, a queue and requires queue-drain behavior.Pads the header away from other fields.Pads away the wip from the other fields.The wip counter.A SingleObserver implementation used for subscribing to the actual SingleSource and replace the current Disposable in a parent AtomicReference.Wraps anotherCompletableObserver
and catches exceptions thrown by itsonSubscribe
,onError
oronComplete
methods despite the protocol forbids it.Wraps anotherMaybeObserver
and catches exceptions thrown by itsonSubscribe
,onSuccess
,onError
oronComplete
methods despite the protocol forbids it.Wraps anotherSingleObserver
and catches exceptions thrown by itsonSubscribe
,onSuccess
oronError
methods despite the protocol forbids it.