Uses of Package
io.reactivex.rxjava3.internal.util
-
Packages that use io.reactivex.rxjava3.internal.util Package Description io.reactivex.rxjava3.disposables Default implementations forDisposable
-based resource management (Disposable
container types) and utility classes to constructDisposables
from callbacks and other types.io.reactivex.rxjava3.internal.jdk8 io.reactivex.rxjava3.internal.observers io.reactivex.rxjava3.internal.operators.completable io.reactivex.rxjava3.internal.operators.flowable io.reactivex.rxjava3.internal.operators.maybe io.reactivex.rxjava3.internal.operators.mixed io.reactivex.rxjava3.internal.operators.observable io.reactivex.rxjava3.internal.operators.parallel io.reactivex.rxjava3.internal.subscribers io.reactivex.rxjava3.internal.util io.reactivex.rxjava3.observers Default wrappers and implementations for observer-based consumer classes and interfaces, including disposable and resource-tracking variants and theTestObserver
that allows unit testingObservable
-,Single
-,Maybe
- andCompletable
-based flows.io.reactivex.rxjava3.processors Classes representing so-called hot backpressure-aware sources, aka processors, that implement theFlowableProcessor
class, the Reactive StreamsProcessor
interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive StreamsPublisher
.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.io.reactivex.rxjava3.subscribers Default wrappers and implementations forSubscriber
-based consumer classes and interfaces, including disposable (DisposableSubscriber
) and resource-tracking (ResourceSubscriber
) variants and theTestSubscriber
that allows unit testingFlowable
-based flows. -
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.disposables Class Description OpenHashSet A simple open hash set with add, remove and clear capabilities only. -
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.internal.jdk8 Class Description AtomicThrowable Atomic container for Throwables including combining and having a terminal state via ExceptionHelper. -
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.internal.observers Class Description ObservableQueueDrain -
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.internal.operators.completable Class Description AtomicThrowable Atomic container for Throwables including combining and having a terminal state via ExceptionHelper. -
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.internal.operators.flowable Class Description AtomicThrowable Atomic container for Throwables including combining and having a terminal state via ExceptionHelper.ErrorMode Indicates when an error from the main source should be reported.QueueDrain -
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.internal.operators.maybe Class Description AtomicThrowable Atomic container for Throwables including combining and having a terminal state via ExceptionHelper. -
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.internal.operators.mixed Class Description AtomicThrowable Atomic container for Throwables including combining and having a terminal state via ExceptionHelper.ErrorMode Indicates when an error from the main source should be reported. -
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.internal.operators.observable Class Description AtomicThrowable Atomic container for Throwables including combining and having a terminal state via ExceptionHelper.ErrorMode Indicates when an error from the main source should be reported.ObservableQueueDrain -
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.internal.operators.parallel Class Description AtomicThrowable Atomic container for Throwables including combining and having a terminal state via ExceptionHelper.ErrorMode Indicates when an error from the main source should be reported. -
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.internal.subscribers Class Description AtomicThrowable Atomic container for Throwables including combining and having a terminal state via ExceptionHelper.QueueDrain -
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.internal.util Class Description AppendOnlyLinkedArrayList.NonThrowingPredicate Predicate interface suppressing the exception.ArrayListSupplier AtomicThrowable Atomic container for Throwables including combining and having a terminal state via ExceptionHelper.EmptyComponent Singleton implementing many interfaces as empty.ErrorMode Indicates when an error from the main source should be reported.HashMapSupplier ListAddBiConsumer NotificationLite Lightweight notification handling utility class.ObservableQueueDrain QueueDrain -
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.observers Class Description AppendOnlyLinkedArrayList A linked-array-list implementation that only supports appending and consumption. -
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.processors Class Description AppendOnlyLinkedArrayList A linked-array-list implementation that only supports appending and consumption.AppendOnlyLinkedArrayList.NonThrowingPredicate Predicate interface suppressing the exception. -
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.subjects Class Description AppendOnlyLinkedArrayList A linked-array-list implementation that only supports appending and consumption.AppendOnlyLinkedArrayList.NonThrowingPredicate Predicate interface suppressing the exception. -
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.subscribers Class Description AppendOnlyLinkedArrayList A linked-array-list implementation that only supports appending and consumption.