Package io.reactivex.rxjava3.operators

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

Interface Summary

Interface	Description
ConditionalSubscriber<T>	A FlowableSubscriber with an additional ConditionalSubscriber.tryOnNext(Object) method that tells the caller the specified value has been accepted or not.
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 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.

Class Summary

Class	Description
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.