Package org.reactfx
Class StatefulStreamBuilderImpl<S,O>
java.lang.Object
org.reactfx.StatefulStreamBuilderImpl<S,O>
- All Implemented Interfaces:
StateMachine.StatefulStreamBuilder<S,
O>
class StatefulStreamBuilderImpl<S,O>
extends Object
implements StateMachine.StatefulStreamBuilder<S,O>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final LL
<EmissionBuilder<S, O>> private final S
private final LL
<TransitionBuilder<S>> private final LL
<TransmissionBuilder<S, O>> -
Constructor Summary
ConstructorsConstructorDescriptionStatefulStreamBuilderImpl
(S initialState, LL<TransitionBuilder<S>> transitions, LL<EmissionBuilder<S, O>> emissions, LL<TransmissionBuilder<S, O>> transmissions) -
Method Summary
Modifier and TypeMethodDescriptionon
(EventStream<I> input) Returns an event stream that emits a value when one of the state machine's input streams causes the state machine to emit a value.
-
Field Details
-
initialState
-
transitions
-
emissions
-
transmissions
-
-
Constructor Details
-
StatefulStreamBuilderImpl
StatefulStreamBuilderImpl(S initialState, LL<TransitionBuilder<S>> transitions, LL<EmissionBuilder<S, O>> emissions, LL<TransmissionBuilder<S, O>> transmissions)
-
-
Method Details
-
on
- Specified by:
on
in interfaceStateMachine.StatefulStreamBuilder<S,
O>
-
toEventStream
Description copied from interface:StateMachine.StatefulStreamBuilder
Returns an event stream that emits a value when one of the state machine's input streams causes the state machine to emit a value.The returned event stream is lazily bound, meaning the associated state machine is subscribed to its inputs only when the returned stream has at least one subscriber. No state transitions take place unless there is a subscriber to the returned stream. If you need to keep the state machine alive even when temporarily not subscribed to the returned stream, you can pin the returned stream.
- Specified by:
toEventStream
in interfaceStateMachine.StatefulStreamBuilder<S,
O>
-