Package | Description |
---|---|
io.reactivex.internal.disposables | |
io.reactivex.internal.fuseable |
Base interfaces and types for supporting operator-fusion.
|
io.reactivex.internal.observers | |
io.reactivex.internal.operators.flowable | |
io.reactivex.internal.operators.maybe | |
io.reactivex.internal.operators.observable | |
io.reactivex.internal.queue | |
io.reactivex.internal.subscribers | |
io.reactivex.internal.subscriptions | |
io.reactivex.internal.util |
Class and Description |
---|
QueueDisposable
An interface extending Queue and Disposable and allows negotiating
the fusion mode between subsequent operators of the
Observable base reactive type. |
QueueFuseable
Represents a SimpleQueue plus the means and constants for requesting a fusion mode.
|
SimpleQueue
A minimalist queue interface without the method bloat of java.util.Collection and java.util.Queue.
|
Class and Description |
---|
QueueFuseable
Represents a SimpleQueue plus the means and constants for requesting a fusion mode.
|
SimpleQueue
A minimalist queue interface without the method bloat of java.util.Collection and java.util.Queue.
|
Class and Description |
---|
QueueDisposable
An interface extending Queue and Disposable and allows negotiating
the fusion mode between subsequent operators of the
Observable base reactive type. |
QueueFuseable
Represents a SimpleQueue plus the means and constants for requesting a fusion mode.
|
SimplePlainQueue
Override of the SimpleQueue interface with no throws Exception on poll().
|
SimpleQueue
A minimalist queue interface without the method bloat of java.util.Collection and java.util.Queue.
|
Class and Description |
---|
FuseToFlowable
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:
|
HasUpstreamPublisher
Interface indicating the implementor has an upstream Publisher-like source available
via
HasUpstreamPublisher.source() method. |
QueueFuseable
Represents a SimpleQueue plus the means and constants for requesting a fusion mode.
|
QueueSubscription
An interface extending Queue and Subscription and allows negotiating
the fusion mode between subsequent operators of the
Flowable base reactive type. |
ScalarCallable
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.
|
SimpleQueue
A minimalist queue interface without the method bloat of java.util.Collection and java.util.Queue.
|
Class and Description |
---|
FuseToMaybe
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:
|
HasUpstreamCompletableSource
Interface indicating the implementor has an upstream CompletableSource-like source available
via
HasUpstreamCompletableSource.source() method. |
HasUpstreamMaybeSource
Interface indicating the implementor has an upstream MaybeSource-like source available
via
HasUpstreamMaybeSource.source() method. |
HasUpstreamSingleSource
Interface indicating the implementor has an upstream SingleSource-like source available
via
HasUpstreamSingleSource.source() method. |
ScalarCallable
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.
|
Class and Description |
---|
FuseToObservable
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:
|
HasUpstreamObservableSource
Interface indicating the implementor has an upstream ObservableSource-like source available
via
HasUpstreamObservableSource.source() method. |
QueueDisposable
An interface extending Queue and Disposable and allows negotiating
the fusion mode between subsequent operators of the
Observable base reactive type. |
QueueFuseable
Represents a SimpleQueue plus the means and constants for requesting a fusion mode.
|
ScalarCallable
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.
|
SimpleQueue
A minimalist queue interface without the method bloat of java.util.Collection and java.util.Queue.
|
Class and Description |
---|
SimplePlainQueue
Override of the SimpleQueue interface with no throws Exception on poll().
|
SimpleQueue
A minimalist queue interface without the method bloat of java.util.Collection and java.util.Queue.
|
Class and Description |
---|
ConditionalSubscriber
A Subscriber with an additional
ConditionalSubscriber.tryOnNext(Object) method that
tells the caller the specified value has been accepted or
not. |
QueueFuseable
Represents a SimpleQueue plus the means and constants for requesting a fusion mode.
|
QueueSubscription
An interface extending Queue and Subscription and allows negotiating
the fusion mode between subsequent operators of the
Flowable base reactive type. |
SimplePlainQueue
Override of the SimpleQueue interface with no throws Exception on poll().
|
SimpleQueue
A minimalist queue interface without the method bloat of java.util.Collection and java.util.Queue.
|
Class and Description |
---|
QueueFuseable
Represents a SimpleQueue plus the means and constants for requesting a fusion mode.
|
QueueSubscription
An interface extending Queue and Subscription and allows negotiating
the fusion mode between subsequent operators of the
Flowable base reactive type. |
SimpleQueue
A minimalist queue interface without the method bloat of java.util.Collection and java.util.Queue.
|
Class and Description |
---|
SimplePlainQueue
Override of the SimpleQueue interface with no throws Exception on poll().
|
SimpleQueue
A minimalist queue interface without the method bloat of java.util.Collection and java.util.Queue.
|
Copyright © 2019. All rights reserved.