Uses of Package
io.reactivex.rxjava3.operators
Packages that use io.reactivex.rxjava3.operators
Package
Description
Base interfaces and types for supporting operator-fusion.
Classes and interfaces for writing advanced operators within and outside RxJava.
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.
-
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.disposablesClassDescriptionAn interface extending
SimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.fuseableClassDescriptionAn interface extending
SimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.jdk8ClassDescriptionA
FlowableSubscriber
with an additionalConditionalSubscriber.tryOnNext(Object)
method that tells the caller the specified value has been accepted or not.An interface extendingSimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.observersClassDescriptionAn interface extending
SimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.A simplified interface for offering, polling and clearing a queue. -
-
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.operators.flowableClassDescriptionA
FlowableSubscriber
with an additionalConditionalSubscriber.tryOnNext(Object)
method that tells the caller the specified value has been accepted or not.An interface extendingSimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.A marker interface indicating that a scalar, constant value is held by the implementing reactive type which can be safely extracted during assembly time can be used for optimization.A simplified interface for offering, polling and clearing a queue.A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.operators.maybeClassDescriptionAn interface extending
SimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.A marker interface indicating that a scalar, constant value is held by the implementing reactive type which can be safely extracted during assembly time can be used for optimization.A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.operators.mixed
-
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.operators.observableClassDescriptionAn interface extending
SimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.A marker interface indicating that a scalar, constant value is held by the implementing reactive type which can be safely extracted during assembly time can be used for optimization.A simplified interface for offering, polling and clearing a queue.A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.operators.parallelClassDescriptionA
FlowableSubscriber
with an additionalConditionalSubscriber.tryOnNext(Object)
method that tells the caller the specified value has been accepted or not.Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.A simplified interface for offering, polling and clearing a queue.A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.operators.singleClassDescriptionAn interface extending
SimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.queueClassDescriptionA simplified interface for offering, polling and clearing a queue.
-
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.subscribersClassDescriptionA
FlowableSubscriber
with an additionalConditionalSubscriber.tryOnNext(Object)
method that tells the caller the specified value has been accepted or not.Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.subscriptionsClassDescriptionRepresents a
SimpleQueue
plus the means and constants for requesting a fusion mode.An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.utilClassDescriptionA simplified interface for offering, polling and clearing a queue.
-
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.operatorsClassDescriptionRepresents a
SimpleQueue
plus the means and constants for requesting a fusion mode.A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.processorsClassDescriptionRepresents a
SimpleQueue
plus the means and constants for requesting a fusion mode.An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.A simplified interface for offering, polling and clearing a queue.A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.subjectsClassDescriptionAn interface extending
SimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.A simplified interface for offering, polling and clearing a queue.A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer.