Package io.reactivex.rxjava4.operators

package io.reactivex.rxjava4.operators

Classes and interfaces for writing advanced operators within and outside RxJava.

Class	Description
ConditionalSubscriber<T>	A FlowableSubscriber with an additional ConditionalSubscriber.tryOnNext(Object) method that tells the caller the specified value has been accepted or not.
DeferredEnumerableSource<T>	Represents an unknown length, deferred iterable source which can be moved forward synchronously and obtain the current item via a simple call once it reports said iterable elements are ready to be consumed.
EnumerableSource<T>	Represents an unknown length iterable source which can be moved forward synchronously and obtain the current item via a simple call.
IndexableSource<T>	Represents a source which can be accessed via a zero-based index synchronously, without going through the usual Streamer.next() calls to obtain the next item.
QueueDisposable<T>	An interface extending SimpleQueue and Disposable and allows negotiating the fusion mode between subsequent operators of the Observable base reactive type.
QueueFuseable<T>	Represents a SimpleQueue plus the means and constants for requesting a fusion mode.
QueueSubscription<T>	An interface extending SimpleQueue and Flow.Subscription and allows negotiating the fusion mode between subsequent operators of the Flowable base reactive type.
ScalarSupplier<T>	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<T>	Override of the SimpleQueue interface with no throws Throwable on poll().
SimpleQueue<T>	A simplified interface for offering, polling and clearing a queue.
SpscArrayQueue<E>	A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.
SpscLinkedArrayQueue<T>	A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer.