Package io.reactivex.rxjava3.internal.fuseable
package io.reactivex.rxjava3.internal.fuseable
Base interfaces and types for supporting operator-fusion.
-
ClassDescriptionRepresents an empty, async-only
QueueFuseable
instance.Represents an empty, async-onlyQueueFuseable
instance that tracks and exposes a canceled/disposed state.Interface indicating a operator implementation can be macro-fused back to Flowable in case the operator goes from Flowable to some other reactive type and then the sequence calls for toFlowable again:FuseToMaybe<T>Interface indicating an operator implementation can be macro-fused back to Maybe in case the operator goes from Maybe to some other reactive type and then the sequence calls for toMaybe again:Interface indicating a operator implementation can be macro-fused back to Observable in case the operator goes from Observable to some other reactive type and then the sequence calls for toObservable again:Interface indicating the implementor has an upstream CompletableSource-like source available viaHasUpstreamCompletableSource.source()
method.Interface indicating the implementor has an upstream MaybeSource-like source available viaHasUpstreamMaybeSource.source()
method.Interface indicating the implementor has an upstream ObservableSource-like source available viaHasUpstreamObservableSource.source()
method.Interface indicating the implementor has an upstream Publisher-like source available viaHasUpstreamPublisher.source()
method.Interface indicating the implementor has an upstream SingleSource-like source available viaHasUpstreamSingleSource.source()
method.