| Class | Description |
|---|---|
| DelimitedStringLinkedList |
Enables a forward-only iteration of string values split by a delimiter across
a linked list of strings.
|
| FlowableCollectWhile<T,R> | |
| FlowableDoOnEmpty<T> |
Calls a consumer just before completion if the stream was empty.
|
| FlowableFetchPagesByRequest | |
| FlowableInsertMaybe<T> | |
| FlowableInsertTimeout<T> | |
| FlowableMapLast<T> | |
| FlowableMatch<A,B,K,C> | |
| FlowableMaxRequest<T> | |
| FlowableMergeInterleave<T> | |
| FlowableMinRequest<T> | |
| FlowableRepeat<T> | |
| FlowableRepeatingTransform<T> | |
| FlowableReverse | |
| FlowableServerSocket | |
| FlowableStateMachine<State,In,Out> | |
| FlowableStringInputStream | |
| FlowableStringSplitSimple | |
| FlowableWindowMinMax<T> |
Uses a double-ended queue and collapses entries when they are redundant
(whenever a value is added to the queue all values at the end of the queue
that are greater or equal to that value are removed).
|
| OnSubscribeCacheResettable<T> | |
| TransformerDecode | |
| TransformerStateMachine<State,In,Out> | |
| TransformerStringSplit |
| Enum | Description |
|---|---|
| FlowableWindowMinMax.Metric |
Copyright © 2013–2020. All rights reserved.