#Reactor.rx Classes and Interfaces

_{#Reactor.rx Classes and Interfaces - 114 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
BarrierStream	A BarrierStream provides a type of Stream into which you can bind Consumers and Functions from arbitrary components.	Class	reactor.rx.stream	Reactor
BatchAction		Class	reactor.rx.action.aggregation	Reactor
BatchSubscription	A Subscription wrapper which requestAuthor:Stephane Maldini	Class	reactor.rx.subscription	Reactor
BehaviorBroadcaster	A Broadcaster is a subclass of Stream which exposes methods for publishing values into the pipeline.	Class	reactor.rx.broadcast	Reactor
BiStreams	A Streams add-on to work with key/value pairs hydrated in Tuple2.	Class	reactor.rx	Reactor
Broadcaster	A Broadcaster is a subclass of Stream which exposes methods for publishing values into the pipeline.	Class	reactor.rx.broadcast	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
ChronicleReaderStream	queue tasks to execute.	Class	reactor.rx.stream.io	Reactor
ChronicleStream		Class	reactor.rx.stream.io	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
DeferredStream	A Publisher supplier that will call the passed supplier on each subscribe call.	Class	reactor.rx.stream	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
DropSubscription	Relationship between a Stream (Publisher) and a Subscriber.	Class	reactor.rx.subscription	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
ErrorStream	A Stream that emits a sigle error signal.	Class	reactor.rx.stream	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
FanOutSubscription	A composite subscription used to achieve pub/sub pattern.	Class	reactor.rx.subscription	Reactor
FilterAction		Class	reactor.rx.action.filter	Reactor
FinallyAction		Class	reactor.rx.action.passive	Reactor
FlowControlAction		Class	reactor.rx.action.control	Reactor
FutureStream	A Stream that emits a result of a Future and then complete.	Class	reactor.rx.stream	Reactor
GroupByAction	Manage a dynamic registry of substreams for a given key extracted from the incoming data.	Class	reactor.rx.action.transformation	Reactor
GroupedStream	The Stream will complete or fail whever the parent groupBy action terminates itself.	Class	reactor.rx.stream	Reactor
IgnoreErrorAction		Class	reactor.rx.action.error	Reactor
IOStreams	A Streams add-on to work with IO components such as ChronicleStreams.	Class	reactor.rx	Reactor
IterableStream	A Stream that emits Iterable values one by one and then complete.	Class	reactor.rx.stream	Reactor
LastAction		Class	reactor.rx.action.aggregation	Reactor
LiftStream	A Stream wrapper that defers a parent stream subscription to the child action subscribe() call.	Class	reactor.rx.stream	Reactor
LoggerAction		Class	reactor.rx.action.passive	Reactor
MapAction		Class	reactor.rx.action.transformation	Reactor
MapStream	A SubscribableMap is an event-driven Map that signals logged operations to its subscribers.	Class	reactor.rx.stream	Reactor
MapStream .MutableSignal		Class	reactor.rx.stream	Reactor
MapStream .Operation	Returns the enum constant of this type with the specified name.	Class	reactor.rx.stream	Reactor
MapStream .Signal		Class	reactor.rx.stream	Reactor
MaterializeAction		Class	reactor.rx.action.transformation	Reactor
MergeAction		Class	reactor.rx.action.combination	Reactor
MergeAction .InnerSubscriber		Class	reactor.rx.action.combination	Reactor
PeriodicTimerStream	A Stream that emits 0 after an initial delay and ever incrementing long counter if the period argument is The TimerStream will manage dedicated timers for new subscriber assigned via	Class	reactor.rx.stream	Reactor
Promise	A Promise is a stateful event container that accepts a single value or error.	Class	reactor.rx	Reactor
Promise .FinalState	Returns the enum constant of this type with the specified name.	Class	reactor.rx	Reactor
Promises	Helper methods for creating Promise instances.	Class	reactor.rx	Reactor
PublisherStream	A Publisher wrapper that takes care of lazy subscribing.	Class	reactor.rx.stream	Reactor
PushSubscription	Relationship between a Stream (Publisher) and a Subscriber.	Class	reactor.rx.subscription	Reactor
RangeStream	A Stream that emits N Long from the inclusive start value defined to the inclusive end and then Since the stream retains the boundaries in a final field, any Subscriber	Class	reactor.rx.stream	Reactor
ReactiveSubscription	Relationship between a Stream (Publisher) and a Subscriber.	Class	reactor.rx.subscription	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
SerializedBroadcaster	A Broadcaster is a subclass of Stream which exposes methods for publishing values into the pipeline.	Class	reactor.rx.broadcast	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
SingleTimerStream	A Stream that emits 0 after an initial delay and then complete The SingleTimerStream will manage dedicated timers for new subscriber assigned via	Class	reactor.rx.stream	Reactor
SingleValueStream	A Stream that emits only one value and then complete.	Class	reactor.rx.stream	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
Streams	A public factory to build Stream, Streams provide for common transformations from a few structures such as Iterable or Future to a Stream, in addition to provide for combinatory operations (merge, switchOnNext.	Class	reactor.rx	Reactor
StreamStateCallbackAction		Class	reactor.rx.action.passive	Reactor
StreamUtils	A simple collection of utils to assist in various tasks such as DebuggingSince:1.	Class	reactor.rx	Reactor
StreamUtils .StreamVisitor		Class	reactor.rx	Reactor
SupplierStream	A Stream that returns the result from Supplier.	Class	reactor.rx.stream	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
WrappedSubscription		Class	reactor.rx.subscription.support	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