Class | Description |
---|---|
BatchAction<T,V> | |
BufferAction<T> | |
BufferShiftAction<T> | |
BufferShiftWhenAction<T> | |
BufferWhenAction<T> | |
CacheAction<T> | |
LastAction<T> | |
SampleAction<T> | |
SortAction<T> | |
WindowAction<T> |
WindowAction is forwarding events on a steam until is reached,
after that streams collected events further, complete it and create a fresh new stream.
|
WindowShiftAction<T> |
WindowAction is forwarding events on a steam until is reached,
after that streams collected events further, complete it and create a fresh new stream.
|
WindowShiftWhenAction<T> |
WindowAction is forwarding events on a steam until is reached,
after that streams collected events further, complete it and create a fresh new stream.
|
WindowWhenAction<T> |
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.
|
Copyright © 2017. All rights reserved.