Uses of Package
io.reactivex.rxjava3.internal.observers
-
Packages that use io.reactivex.rxjava3.internal.observers Package Description io.reactivex.rxjava3.internal.jdk8 io.reactivex.rxjava3.internal.observers io.reactivex.rxjava3.internal.operators.maybe io.reactivex.rxjava3.internal.operators.observable io.reactivex.rxjava3.internal.operators.single io.reactivex.rxjava3.subjects Classes representing so-called hot sources, aka subjects, that implement a base reactive class and the respective consumer type at once to allow forms of multicasting events to multiple consumers as well as consuming another base reactive type of their kind. -
Classes in io.reactivex.rxjava3.internal.observers used by io.reactivex.rxjava3.internal.jdk8 Class Description BasicFuseableObserver Base class for a fuseable intermediate observer.BasicIntQueueDisposable An abstract QueueDisposable implementation, extending an AtomicInteger, that defaults all unnecessary Queue methods to throw UnsupportedOperationException.DeferredScalarDisposable Represents a fuseable container for a single value. -
Classes in io.reactivex.rxjava3.internal.observers used by io.reactivex.rxjava3.internal.observers Class Description AbstractDisposableAutoRelease Wraps lambda callbacks and when the upstream terminates or the observer gets disposed, removes itself from aCompositeDisposable
.BasicIntQueueDisposable An abstract QueueDisposable implementation, extending an AtomicInteger, that defaults all unnecessary Queue methods to throw UnsupportedOperationException.BlockingBaseObserver DeferredScalarDisposable Represents a fuseable container for a single value.InnerQueuedObserver Subscriber that can fuse with the upstream and calls a support interface whenever an event is available.InnerQueuedObserverSupport Interface to allow the InnerQueuedSubscriber to call back a parent with signals.QueueDrainSubscriberPad0 Pads the header away from other fields.QueueDrainSubscriberPad2 Pads away the wip from the other fields.QueueDrainSubscriberWip The wip counter. -
Classes in io.reactivex.rxjava3.internal.observers used by io.reactivex.rxjava3.internal.operators.maybe Class Description BasicIntQueueDisposable An abstract QueueDisposable implementation, extending an AtomicInteger, that defaults all unnecessary Queue methods to throw UnsupportedOperationException.BasicQueueDisposable An abstract QueueDisposable implementation that defaults all unnecessary Queue methods to throw UnsupportedOperationException.DeferredScalarDisposable Represents a fuseable container for a single value. -
Classes in io.reactivex.rxjava3.internal.observers used by io.reactivex.rxjava3.internal.operators.observable Class Description BasicFuseableObserver Base class for a fuseable intermediate observer.BasicIntQueueDisposable An abstract QueueDisposable implementation, extending an AtomicInteger, that defaults all unnecessary Queue methods to throw UnsupportedOperationException.BasicQueueDisposable An abstract QueueDisposable implementation that defaults all unnecessary Queue methods to throw UnsupportedOperationException.InnerQueuedObserver Subscriber that can fuse with the upstream and calls a support interface whenever an event is available.InnerQueuedObserverSupport Interface to allow the InnerQueuedSubscriber to call back a parent with signals.QueueDrainObserver 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. -
Classes in io.reactivex.rxjava3.internal.observers used by io.reactivex.rxjava3.internal.operators.single Class Description BasicIntQueueDisposable An abstract QueueDisposable implementation, extending an AtomicInteger, that defaults all unnecessary Queue methods to throw UnsupportedOperationException.DeferredScalarDisposable Represents a fuseable container for a single value. -
Classes in io.reactivex.rxjava3.internal.observers used by io.reactivex.rxjava3.subjects Class Description BasicIntQueueDisposable An abstract QueueDisposable implementation, extending an AtomicInteger, that defaults all unnecessary Queue methods to throw UnsupportedOperationException.DeferredScalarDisposable Represents a fuseable container for a single value.