Package io.reactivex.rxjava3.operators
Classes and interfaces for writing advanced operators within and outside RxJava.
-
Interface Summary Interface Description ConditionalSubscriber<T> AFlowableSubscriber
with an additionalConditionalSubscriber.tryOnNext(Object)
method that tells the caller the specified value has been accepted or not.QueueDisposable<T> An interface extendingSimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.QueueFuseable<T> Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.QueueSubscription<T> An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
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> 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.