Uses of Package
io.reactivex.rxjava3.operators
Packages that use io.reactivex.rxjava3.operators
Package
Description
Base interfaces and types for supporting operator-fusion.
Classes and interfaces for writing advanced operators within and outside RxJava.
-
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.disposablesClassDescriptionAn interface extending
SimpleQueueandDisposableand allows negotiating the fusion mode between subsequent operators of theObservablebase reactive type.Represents aSimpleQueueplus the means and constants for requesting a fusion mode.A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.fuseableClassDescriptionAn interface extending
SimpleQueueandDisposableand allows negotiating the fusion mode between subsequent operators of theObservablebase reactive type.Represents aSimpleQueueplus the means and constants for requesting a fusion mode.An interface extendingSimpleQueueandSubscriptionand allows negotiating the fusion mode between subsequent operators of theFlowablebase reactive type.A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.observersClassDescriptionAn interface extending
SimpleQueueandDisposableand allows negotiating the fusion mode between subsequent operators of theObservablebase reactive type.Represents aSimpleQueueplus the means and constants for requesting a fusion mode.A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.operators.flowableClassDescriptionAn interface extending
SimpleQueueandDisposableand allows negotiating the fusion mode between subsequent operators of theObservablebase reactive type.Represents aSimpleQueueplus the means and constants for requesting a fusion mode.An interface extendingSimpleQueueandSubscriptionand allows negotiating the fusion mode between subsequent operators of theFlowablebase 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.A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.operators.maybeClassDescriptionA 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.
-
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.operators.observableClassDescriptionAn interface extending
SimpleQueueandDisposableand allows negotiating the fusion mode between subsequent operators of theObservablebase reactive type.Represents aSimpleQueueplus the means and constants for requesting a fusion mode.An interface extendingSimpleQueueandSubscriptionand allows negotiating the fusion mode between subsequent operators of theFlowablebase 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.A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.queueClassDescriptionA simplified interface for offering, polling and clearing a queue.
-
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.subscribersClassDescriptionA
FlowableSubscriberwith an additionalConditionalSubscriber.tryOnNext(Object)method that tells the caller the specified value has been accepted or not.Represents aSimpleQueueplus the means and constants for requesting a fusion mode.An interface extendingSimpleQueueandSubscriptionand allows negotiating the fusion mode between subsequent operators of theFlowablebase reactive type.A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.subscriptionsClassDescriptionRepresents a
SimpleQueueplus the means and constants for requesting a fusion mode.An interface extendingSimpleQueueandSubscriptionand allows negotiating the fusion mode between subsequent operators of theFlowablebase reactive type.A simplified interface for offering, polling and clearing a queue. -
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.internal.utilClassDescriptionA simplified interface for offering, polling and clearing a queue.
-
Classes in io.reactivex.rxjava3.operators used by io.reactivex.rxjava3.operatorsClassDescriptionRepresents a
SimpleQueueplus the means and constants for requesting a fusion mode.A simplified interface for offering, polling and clearing a queue.