RxJava 3 3.1.8 · io.reactivex.rxjava3.operators

Interface Summary

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

Modifier and Type	Class and Description
public class	SpscArrayQueue< the element type of the queue E> A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.
public class	SpscLinkedArrayQueue< the contained value type T> A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer.