Package io.reactivex.rxjava3.operators

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

See: Description

Interface Summary

Interface	Description
ConditionalSubscriber	A FlowableSubscriber with an additional ConditionalSubscriber.tryOnNext(Object) method that tells the caller the specified value has been accepted or not.
QueueDisposable	An interface extending SimpleQueue and Disposable and allows negotiating the fusion mode between subsequent operators of the Observable base reactive type.
QueueFuseable	Represents a SimpleQueue plus the means and constants for requesting a fusion mode.
QueueSubscription	An interface extending SimpleQueue and Subscription and allows negotiating the fusion mode between subsequent operators of the Flowable 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	Override of the SimpleQueue interface with no throws Throwable on poll().
SimpleQueue	A simplified interface for offering, polling and clearing a queue.

Class Summary

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

Package io.reactivex.rxjava3.operators Description

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