#Reactor.rx.action Classes and Interfaces

_{#Reactor.rx.action Classes and Interfaces - 78 results found.}

Name	Description	Type	Package	Framework
Action	An Action is a reactive component to subscribe to a Publisher and in particular to a Stream.	Class	reactor.rx.action	Reactor
AdaptiveConsumerAction		Class	reactor.rx.action.terminal	Reactor
AfterAction		Class	reactor.rx.action.passive	Reactor
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
CallbackAction		Class	reactor.rx.action.passive	Reactor
CombineLatestAction		Class	reactor.rx.action.combination	Reactor
CombineLatestAction .InnerSubscriber		Class	reactor.rx.action.combination	Reactor
CombineLatestAction .Zippable		Class	reactor.rx.action.combination	Reactor
CompositeAction	Create a Processor where a given head/tail couple is provided as a Stream (Input upstream) and Action (OutputSince:2.	Class	reactor.rx.action	Reactor
ConcatAction		Class	reactor.rx.action.combination	Reactor
ConsumerAction		Class	reactor.rx.action.terminal	Reactor
Control	An interface generally associated with a Stream terminal action such as Stream.	Interface	reactor.rx.action	Reactor
CountAction		Class	reactor.rx.action.metrics	Reactor
DefaultIfEmptyAction		Class	reactor.rx.action.transformation	Reactor
DefaultSubscriber		Class	reactor.rx.action.support	Reactor
DematerializeAction		Class	reactor.rx.action.transformation	Reactor
DispatcherAction		Class	reactor.rx.action.control	Reactor
DistinctAction		Class	reactor.rx.action.filter	Reactor
DistinctUntilChangedAction		Class	reactor.rx.action.filter	Reactor
DynamicMergeAction		Class	reactor.rx.action.combination	Reactor
ElapsedAction		Class	reactor.rx.action.metrics	Reactor
ElementAtAction		Class	reactor.rx.action.filter	Reactor
ErrorAction		Class	reactor.rx.action.error	Reactor
ErrorReturnAction		Class	reactor.rx.action.error	Reactor
ErrorWithValueAction		Class	reactor.rx.action.error	Reactor
ExistsAction		Class	reactor.rx.action.conditional	Reactor
FallbackAction		Class	reactor.rx.action.error	Reactor
FanInAction	The best moment of my life so far, not.	Class	reactor.rx.action.combination	Reactor
FanInAction .InnerSubscriber	Execute the logic of the action, accepting the given parameter.	Class	reactor.rx.action.combination	Reactor
FanInSubscription		Class	reactor.rx.action.combination	Reactor
FanInSubscription .InnerSubscription		Class	reactor.rx.action.combination	Reactor
FilterAction		Class	reactor.rx.action.filter	Reactor
FinallyAction		Class	reactor.rx.action.passive	Reactor
FlowControlAction		Class	reactor.rx.action.control	Reactor
GroupByAction	Manage a dynamic registry of substreams for a given key extracted from the incoming data.	Class	reactor.rx.action.transformation	Reactor
IgnoreErrorAction		Class	reactor.rx.action.error	Reactor
LastAction		Class	reactor.rx.action.aggregation	Reactor
LoggerAction		Class	reactor.rx.action.passive	Reactor
MapAction		Class	reactor.rx.action.transformation	Reactor
MaterializeAction		Class	reactor.rx.action.transformation	Reactor
MergeAction		Class	reactor.rx.action.combination	Reactor
MergeAction .InnerSubscriber		Class	reactor.rx.action.combination	Reactor
ReduceByKeyAction		Class	reactor.rx.action.pair	Reactor
RepeatAction		Class	reactor.rx.action.control	Reactor
RepeatWhenAction		Class	reactor.rx.action.control	Reactor
RetryAction		Class	reactor.rx.action.error	Reactor
RetryWhenAction		Class	reactor.rx.action.error	Reactor
SampleAction		Class	reactor.rx.action.aggregation	Reactor
ScanAction		Class	reactor.rx.action.transformation	Reactor
ScanByKeyAction		Class	reactor.rx.action.pair	Reactor
Signal	A domain representation of a Reactive Stream signal.	Class	reactor.rx.action	Reactor
Signal .Type	Only happens once, a complete signal is used to confirm the successful end of the data sequence flowing in aOnly happens once, a complete signal is used to confirm the error end of the data sequence flowing in a	Class	reactor.rx.action	Reactor
SkipAction		Class	reactor.rx.action.filter	Reactor
SkipUntilTimeout		Class	reactor.rx.action.filter	Reactor
SortAction		Class	reactor.rx.action.aggregation	Reactor
SplitAction		Class	reactor.rx.action.transformation	Reactor
StreamStateCallbackAction		Class	reactor.rx.action.passive	Reactor
SwitchAction		Class	reactor.rx.action.combination	Reactor
TakeAction		Class	reactor.rx.action.filter	Reactor
TakeUntilTimeout		Class	reactor.rx.action.filter	Reactor
TakeWhileAction		Class	reactor.rx.action.filter	Reactor
TapAndControls		Class	reactor.rx.action.support	Reactor
ThrottleRequestAction		Class	reactor.rx.action.control	Reactor
ThrottleRequestWhenAction		Class	reactor.rx.action.control	Reactor
TimeoutAction		Class	reactor.rx.action.error	Reactor
TimestampAction		Class	reactor.rx.action.metrics	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
ZipAction		Class	reactor.rx.action.combination	Reactor
ZipAction .InnerSubscriber		Class	reactor.rx.action.combination	Reactor
ZipAction .Zippable		Class	reactor.rx.action.combination	Reactor

Search Java Classes and Packages