Package io.reactivex.rxjava3.operators
package io.reactivex.rxjava3.operators
Classes and interfaces for writing advanced operators within and outside RxJava.
-
ClassDescriptionA
FlowableSubscriber
with an additionalConditionalSubscriber.tryOnNext(Object)
method that tells the caller the specified value has been accepted or not.An interface extendingSimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.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.SimpleQueue<T>A simplified interface for offering, polling and clearing a queue.A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer.