| Interface | Description |
|---|---|
| BasicEmitter<T> |
Abstraction over a Subscriber.
|
| FlowableAsyncEmitter<T> |
Provides an API on top of the
Emitter signals that allow
setting and replacing a Cancellable resource to be cancelled
when the associated flow is cancelled. |
| PartialCollectEmitter<T,I,A,R> |
Provides callbacks and methods to support the partial collect operator:
access to cached elements, save and retrieve an input index and accumulator and
produce the output instance.
|
| Class | Description |
|---|---|
| BasicMergeSubscription<T> |
Subscription coordinator that merges items from a fixed set of source Publishers by
picking the smallest available next item from them based on a Comparator.
|
| Flowables |
Utility class to create Flowable sources.
|
| FlowableTransformers |
Additional operators in the form of
FlowableTransformer,
use Flowable.compose(FlowableTransformer)
to apply the operators to an existing sequence. |
| Observables |
Utility class to create Observable sources.
|
| ObservableTransformers |
Additional operators in the form of
ObservableTransformer,
use Observable.compose(ObservableTransformer)
to apply the operators to an existing sequence. |
| Enum | Description |
|---|---|
| ExpandStrategy |
Represents the strategies for recursive expansion with the
expand() operator. |