Top Description Interfaces Classes

[default module]

Package io.reactivex.rxjava3.internal.fuseable

Base interfaces and types for supporting operator-fusion.

Interface Summary

Modifier and Type	Interface and Description
public interface	FuseToFlowable< the value type 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: `Single<Integer> single = Flowable.range(1, 10).reduce((a, b) -> a + b); Flowable<Integer> flowable = single.toFlowable();`
public interface	FuseToMaybe< the value type 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: `Single<Integer> single = Maybe.just(1).isEmpty(); Maybe<Integer> maybe = single.toMaybe();`
public interface	FuseToObservable< the value type 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: `Single<Integer> single = Observable.range(1, 10).reduce((a, b) -> a + b); Observable<Integer> observable = single.toObservable();`
public interface	HasUpstreamCompletableSource Interface indicating the implementor has an upstream CompletableSource-like source available via `source()` method.
public interface	HasUpstreamMaybeSource< the value type T> Interface indicating the implementor has an upstream MaybeSource-like source available via `source()` method.
public interface	HasUpstreamObservableSource< the value type T> Interface indicating the implementor has an upstream ObservableSource-like source available via `source()` method.
public interface	HasUpstreamPublisher< the value type T> Interface indicating the implementor has an upstream Publisher-like source available via `source()` method.
public interface	HasUpstreamSingleSource< the value type T> Interface indicating the implementor has an upstream SingleSource-like source available via `source()` method.

Class Summary

Modifier and Type	Class and Description
public abstract class	AbstractEmptyQueueFuseable< the output value type T> Represents an empty, async-only `QueueFuseable` instance.
public class	CancellableQueueFuseable< the output value type T> Represents an empty, async-only `QueueFuseable` instance that tracks and exposes a canceled/disposed state.