Package io.reactivex.rxjava3.internal.fuseable
Base interfaces and types for supporting operator-fusion.
-
Interface Summary Interface Description FuseToFlowable<T> 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:FuseToObservable<T> 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:HasUpstreamCompletableSource Interface indicating the implementor has an upstream CompletableSource-like source available viaHasUpstreamCompletableSource.source()
method.HasUpstreamMaybeSource<T> Interface indicating the implementor has an upstream MaybeSource-like source available viaHasUpstreamMaybeSource.source()
method.HasUpstreamObservableSource<T> Interface indicating the implementor has an upstream ObservableSource-like source available viaHasUpstreamObservableSource.source()
method.HasUpstreamPublisher<T> Interface indicating the implementor has an upstream Publisher-like source available viaHasUpstreamPublisher.source()
method.HasUpstreamSingleSource<T> Interface indicating the implementor has an upstream SingleSource-like source available viaHasUpstreamSingleSource.source()
method. -
Class Summary Class Description AbstractEmptyQueueFuseable<T> Represents an empty, async-onlyQueueFuseable
instance.CancellableQueueFuseable<T> Represents an empty, async-onlyQueueFuseable
instance that tracks and exposes a canceled/disposed state.