Package org.reactfx

Interface Summary

Interface	Description
AwaitingEventStream<T>	An event stream that indicates whether there is a pending event that can be expected to be emitted in the future.
CompletionStageStream<T>
Connectable<T>	Interface for objects that can be (lazily) connected to event streams.
ConnectableEventSink<T>
ConnectableEventStream<T>
EventSink<T>
EventStream<T>	Stream of values (events).
Guard
Guardian	Deprecated. superseded by Suspendable.
InputHandler
Observable<O>	Anything that can be observed, that is have an observer added and removed.
ProperEventStream<T>	Trait to be mixed into ObservableBase to obtain default implementation of some EventStream methods on top of Observable methods and get additional helper methods for proper event streams implemented as default methods on top of ProperObservable methods.
ProperObservable<O,T>	An Observable that maintains a collection of registered observers and notifies them when a change occurs.
StateMachine.InitialState<S>
StateMachine.ObservableStateBuilder<S>
StateMachine.ObservableStateBuilderOn<S,I>
StateMachine.StatefulStreamBuilder<S,O>
StateMachine.StatefulStreamBuilderOn<S,O,I>
Subscription
Suspendable	Interface for objects that can be temporarily suspended, where the definition of "suspended" depends on the context.
SuspendableEventStream<T>	An event stream whose emission of events can be suspended temporarily.
Suspender<S extends Suspendable>	Suspender is an object capable of suspending another suspendable object.
SuspenderStream<T,S extends Suspendable>	An event stream that suspends a suspendable object during emission.
TaskStream<T>
Toggle	Observable boolean that changes value when suspended.

Class Summary

Class	Description
AbstractReducibleEventStream<T>
AccumulateBetweenStream<T,A>
AccumulateUntilLaterStream<T,A>
AccumulatingStream<T,U>	See EventStream.accumulate(BiFunction, Function)
AccumulativeEventStream<T,A>
Await<T,F>
AwaitLatest<T,F>
BiGuard
BiGuardian
BiSubscription
BiSuspendable
Change<T>	Represents a change of a value.
CloseableOnceGuard
ConnectableEventSource<T>
DefaultEventStream<T>
DistinctStream<T>	See EventStream.distinct()
EmissionBuilder<S,O>
EmitBothOnEachStream<A,I>	EventStream.emitBothOnEach(EventStream)
EmitOnEachStream<T>	See EventStream.emitOnEach(EventStream)
EmitOnStream<T>
EventSource<T>	EventSource is an EventSink that serves also as an EventStream - every value pushed to EventSource is immediately emitted by it.
EventStreamBase<T>	Base class for event streams.
EventStreams
EventStreams.ExclusivePocket<T>
EventStreams.Never<T>
EventStreams.Pocket<T>
FilterMapStream<T,U>
FilterStream<T>
FlatMapOptStream<T,U>
FlatMapStream<T,U>	See EventStream.flatMap(Function)
ForgetfulEventStream<T>	See EventStream.forgetful()
HookStream<T>
Indicator	Deprecated. Indicator is unsafe on recursion: it may report misleading changes.
InitialStateImpl<S>
InputHandlerBuilder<S,TGT>
LatestNStream<T>	See EventStream.latestN(int)
LimitedInvocationSubscriber<T>
MappedStream<T,U>	See EventStream.map(Function)
MappedToCompletionStageStream<T,U>
MappedToTaskStream<T,U>
MultiGuard
MultiGuardian
MultiSubscription
MultiSuspendable
ObservableBase<O,T>	Base class for observable objects.
ObservableStateBuilderImpl<S>
ObservableStateBuilderOnImpl<S,I>
PausableEventStream<T>	See EventStream.pausable()
ProxyObservable<O,P,U extends Observable<P>>	An Observable that does not maintain its own collection of observers, but rather adapts and registers every given observer with the underlying Observable
RecursiveStream<T>
ReducibleEventStream<T>	See EventStream.reducible(BinaryOperator)
RepeatOnStream<T>	See EventStream.repeatOn(EventStream)
RigidObservable<O>	An observable that does not change and does not produce any notifications.
ScheduledExecutorServiceTimer
StatefulStream<S,O>
StatefulStreamBuilderImpl<S,O>
StatefulStreamBuilderOnImpl<S,O,I>
StateMachine
StateStream<S>
StreamBinding<T>
SuccessionReducingStream<I,O>
SuppressibleEventStream<T>
SuspendableBase<O,T,A>
SuspendableBoolean
SuspendableEventStreamBase<T,A>
SuspendableNo	Observable boolean value that is normally false, but is true when suspended.
SuspendableYes	Observable boolean value that is normally true, but is false when suspended.
SuspendedWhenStream<T>
SuspenderBase<O,T,S extends Suspendable>
SuspenderStreamImpl<T,S extends Suspendable>
ThenAccumulateForStream<T,A>
ThreadBridge<T>
ToggleFromVal
TransitionBuilder<S>
TransmissionBuilder<S,O>

Enum Summary

Enum	Description
ThenAccumulateForStream.State