See: Description
| Interface | Description |
|---|---|
| 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:
Single<Integer> single = Maybe.just(1).isEmpty();
Maybe<Integer> maybe = single.toMaybe();
The
Single.toMaybe() will check for this interface and call the FuseToMaybe.fuseToMaybe()
to return a Maybe which could be the Maybe-specific implementation of isEmpty(). |
| 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:
Single<Integer> single = Observable.range(1, 10).reduce((a, b) -> a + b);
Observable<Integer> observable = single.toObservable();
The
Single.toObservable() will check for this interface and call the FuseToObservable.fuseToObservable()
to return an Observable which could be the Observable-specific implementation of reduce(BiFunction). |
| HasUpstreamCompletableSource |
Interface indicating the implementor has an upstream CompletableSource-like source available
via
HasUpstreamCompletableSource.source() method. |
| HasUpstreamMaybeSource<T> |
Interface indicating the implementor has an upstream MaybeSource-like source available
via
HasUpstreamMaybeSource.source() method. |
| HasUpstreamObservableSource<T> |
Interface indicating the implementor has an upstream ObservableSource-like source available
via
HasUpstreamObservableSource.source() method. |
| HasUpstreamSingleSource<T> |
Interface indicating the implementor has an upstream SingleSource-like source available
via
HasUpstreamSingleSource.source() method. |
| QueueDisposable<T> |
An interface extending Queue and Disposable and allows negotiating
the fusion mode between subsequent operators of the
Observable base reactive type. |
| QueueFuseable<T> |
Represents a SimpleQueue plus the means and constants for requesting a fusion mode.
|
| ScalarCallable<T> |
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.
|
| SimplePlainQueue<T> |
Override of the SimpleQueue interface with no throws Exception on poll().
|
| SimpleQueue<T> |
A minimalist queue interface without the method bloat of java.util.Collection and java.util.Queue.
|