See: Description
Interface | Description |
---|---|
ConditionalSubscriber<T> |
A Subscriber with an additional
ConditionalSubscriber.tryOnNext(Object) method that
tells the caller the specified value has been accepted or
not. |
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
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. |
HasUpstreamPublisher<T> |
Interface indicating the implementor has an upstream Publisher-like source available
via
HasUpstreamPublisher.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.
|
QueueSubscription<T> |
An interface extending Queue and Subscription and allows negotiating
the fusion mode between subsequent operators of the
Flowable base reactive type. |
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.
|
Copyright © 2019. All rights reserved.