Uses of Package
io.reactivex.rxjava3.operators
-
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.disposables Class Description QueueDisposable An interface extendingSimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.QueueFuseable Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.SimpleQueue A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.fuseable Class Description QueueDisposable An interface extendingSimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.QueueFuseable Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.QueueSubscription An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.SimpleQueue A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.jdk8 Class Description ConditionalSubscriber AFlowableSubscriber
with an additionalConditionalSubscriber.tryOnNext(Object)
method that tells the caller the specified value has been accepted or not.QueueDisposable An interface extendingSimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.QueueFuseable Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.QueueSubscription An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.SimpleQueue A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.observers Class Description QueueDisposable An interface extendingSimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.QueueFuseable Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.SimplePlainQueue SimpleQueue A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.operators.completable Class Description SimpleQueue A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.operators.flowable Class Description ConditionalSubscriber AFlowableSubscriber
with an additionalConditionalSubscriber.tryOnNext(Object)
method that tells the caller the specified value has been accepted or not.QueueDisposable An interface extendingSimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.QueueFuseable Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.QueueSubscription An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.ScalarSupplier 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.SimplePlainQueue SimpleQueue A simplified interface for offering, polling and clearing a queue.SpscArrayQueue A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.SpscLinkedArrayQueue 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.maybe Class Description QueueDisposable An interface extendingSimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.QueueFuseable Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.QueueSubscription An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.ScalarSupplier 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.SimpleQueue A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.operators.mixed Class Description SimpleQueue A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.operators.observable Class Description QueueDisposable An interface extendingSimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.QueueFuseable Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.QueueSubscription An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.ScalarSupplier 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.SimplePlainQueue SimpleQueue A simplified interface for offering, polling and clearing a queue.SpscLinkedArrayQueue 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.parallel Class Description ConditionalSubscriber AFlowableSubscriber
with an additionalConditionalSubscriber.tryOnNext(Object)
method that tells the caller the specified value has been accepted or not.QueueFuseable Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.QueueSubscription An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.SimplePlainQueue SimpleQueue A simplified interface for offering, polling and clearing a queue.SpscArrayQueue 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.single Class Description QueueDisposable An interface extendingSimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.QueueFuseable Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.QueueSubscription An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.SimpleQueue A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.queue Class Description SimplePlainQueue SimpleQueue A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.subscribers Class Description ConditionalSubscriber AFlowableSubscriber
with an additionalConditionalSubscriber.tryOnNext(Object)
method that tells the caller the specified value has been accepted or not.QueueFuseable Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.QueueSubscription An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.SimplePlainQueue SimpleQueue A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.subscriptions Class Description QueueFuseable Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.QueueSubscription An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.SimpleQueue A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.util Class Description SimplePlainQueue SimpleQueue A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.operators Class Description QueueFuseable Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.SimplePlainQueue SimpleQueue A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.processors Class Description QueueFuseable Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.QueueSubscription An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.SimpleQueue A simplified interface for offering, polling and clearing a queue.SpscLinkedArrayQueue 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.subjects Class Description QueueDisposable An interface extendingSimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.QueueFuseable Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.SimpleQueue A simplified interface for offering, polling and clearing a queue.SpscLinkedArrayQueue A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer.