Accumulate |
Apply func(value, state) which is returning new state and value to emit |
Cache |
Caching the emitted values (make a stateless publisher stateful) |
CatchException |
Catching exceptions of following operators in the pipeline |
CombineLatest |
Combine the latest emit of multiple publishers and emit the combination |
Debounce |
Emit a value only after a given idle time (emits meanwhile are skipped). |
Delay |
Emit every value delayed by the given time. |
Filter |
Filters values based on a predicate function |
Map |
Apply a function to each emitted value |
MapAsync |
Apply a coroutine to each emitted value allowing async processing |
MapThreaded |
Apply a blocking function to each emitted value allowing threaded processing |
Merge |
Merge emits of multiple publishers into one stream |
Partition |
Group size emits into one emit as tuple |
Reduce |
Like Map but with additional previous result as argument to the function. |
Replace |
Replace each received value by the given value |
Sample |
Emit the last received value periodically |
SlidingWindow |
Group size emitted values overlapping |
Switch |
Emit selected source mapped by mapping |
Throttle |
Rate limit emits by the given time |