Package reactor.core.action

Interface Summary

Interface	Description
Flushable<T>	Component that can be flushed
Pipeline<T>	Component that can be injected with Actions and consume flush events for releasing buffer owned by the pipeline

Class Summary

Class	Description
Action<T>	Base class for all Composable actions such as map, reduce, filter...
ActionUtils
ActionUtils.ActionVisitor
BatchAction<T>
BufferAction<T>
CallbackAction<T>
CallbackEventAction<T>
CollectAction<T>
ConnectAction<T>
CountAction<T>
DistinctAction<T>
FilterAction<T>
FlushableAction
ForEachAction<T>
MapAction<T,V>
MapManyAction<T,V,C extends Composable<V>>
MovingWindowAction<T>	MovingWindowAction is collecting maximum events on a stream until is reached, after that steams collected events further, and continues collecting without clearing the list.
ReduceAction<T,A>
ScanAction<T,A>
SupplyAction<T>
TimeoutAction<T>
WhenAction<T>
WindowAction<T>	WindowAction is collecting events on a steam until is reached, after that streams collected events further, clears the internal collection and starts collecting items from empty list.