Uses of Package
io.reactivex.rxjava3.internal.util
Packages that use io.reactivex.rxjava3.internal.util
Package
Description
Default implementations for
Disposable
-based resource management
(Disposable
container types) and utility classes to construct
Disposables
from callbacks and other types.Default wrappers and implementations for observer-based consumer classes and interfaces,
including disposable and resource-tracking variants and
the
TestObserver
that allows unit testing
Observable
-, Single
-,
Maybe
- and Completable
-based flows.Classes representing so-called hot backpressure-aware sources, aka processors,
that implement the
FlowableProcessor
class,
the Reactive Streams Processor
interface
to allow forms of multicasting events to one or more subscribers as well as consuming another
Reactive Streams Publisher
.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.
Default wrappers and implementations for
Subscriber
-based consumer classes and interfaces,
including disposable (DisposableSubscriber
) and resource-tracking
(ResourceSubscriber
)
variants and the TestSubscriber
that allows unit testing
Flowable
-based flows.-
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.disposables
-
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.internal.jdk8ClassDescriptionAtomic 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
-
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.internal.operators.completableClassDescriptionAtomic 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.flowableClassDescriptionAtomic container for Throwables including combining and having a terminal state via ExceptionHelper.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.maybeClassDescriptionAtomic 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.mixedClassDescriptionAtomic container for Throwables including combining and having a terminal state via ExceptionHelper.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.observableClassDescriptionAtomic container for Throwables including combining and having a terminal state via ExceptionHelper.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.parallelClassDescriptionAtomic container for Throwables including combining and having a terminal state via ExceptionHelper.Indicates when an error from the main source should be reported.
-
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.internal.subscribersClassDescriptionAtomic 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.utilClassDescriptionPredicate interface suppressing the exception.Atomic container for Throwables including combining and having a terminal state via ExceptionHelper.Singleton implementing many interfaces as empty.Indicates when an error from the main source should be reported.Lightweight notification handling utility class.
-
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.observersClassDescriptionA linked-array-list implementation that only supports appending and consumption.
-
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.processorsClassDescriptionA linked-array-list implementation that only supports appending and consumption.Predicate interface suppressing the exception.
-
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.subjectsClassDescriptionA linked-array-list implementation that only supports appending and consumption.Predicate interface suppressing the exception.
-
Classes in io.reactivex.rxjava3.internal.util used by io.reactivex.rxjava3.subscribersClassDescriptionA linked-array-list implementation that only supports appending and consumption.