Name | Description | Type | Package | Framework |
BatchAction | Class | reactor.rx.action.aggregation | Reactor | |
BufferAction | Class | reactor.rx.action.aggregation | Reactor | |
BufferShiftAction | Class | reactor.rx.action.aggregation | Reactor | |
BufferShiftWhenAction | Class | reactor.rx.action.aggregation | Reactor | |
BufferWhenAction | Class | reactor.rx.action.aggregation | Reactor | |
CacheAction | Class | reactor.rx.action.aggregation | Reactor | |
LastAction | Class | reactor.rx.action.aggregation | Reactor | |
SampleAction | Class | reactor.rx.action.aggregation | Reactor | |
SortAction | Class | reactor.rx.action.aggregation | Reactor | |
WindowAction | WindowAction is forwarding events on a steam until is reached, after that streams collected events further, complete it and create a fresh new stream. | Class | reactor.rx.action.aggregation | Reactor |
WindowShiftAction | WindowAction is forwarding events on a steam until is reached, after that streams collected events further, complete it and create a fresh new stream. | Class | reactor.rx.action.aggregation | Reactor |
WindowShiftWhenAction | WindowAction is forwarding events on a steam until is reached, after that streams collected events further, complete it and create a fresh new stream. | Class | reactor.rx.action.aggregation | Reactor |
WindowWhenAction | WindowAction is forwarding events on a steam until returned stream emits a signal, after that streams collected events further, complete it and create a fresh new stream. | Class | reactor.rx.action.aggregation | Reactor |