Top Fields Constructors Methods
org.reactfx

pack-priv Class StatefulStream<S, O>

Located in compilation unit of org.reactfx.StateMachine.

extends EventStreamBase<O>
Class Inheritance

Field Summary

Modifier and TypeField and Description
private final List<InputHandler>
inputHandlers

private S
state

Constructor Summary

AccessConstructor and Description
pack-priv
StatefulStream(S initialState, LL<TransitionBuilder<S>> transitions, LL<EmissionBuilder<S, O>> emissions, LL<TransmissionBuilder<S, O>> transmissions)

Method Summary

Modifier and TypeMethod and Description
private void
handleEmission(Function<S, Optional<O>> emission)

private void
handleTransition(Function<S, S> transition)

private void
handleTransmission(Function<S, Tuple2<S, Optional<O>>> transmission)

protected Subscription
observeInputs()

Implements abstract org.reactfx.ObservableBase.observeInputs.

Starts observing this observable's input(s), if any.

Field Detail

inputHandlersback to summary
private final List<InputHandler> inputHandlers
stateback to summary
private S state

Constructor Detail

StatefulStreamback to summary
pack-priv StatefulStream(S initialState, LL<TransitionBuilder<S>> transitions, LL<EmissionBuilder<S, O>> emissions, LL<TransmissionBuilder<S, O>> transmissions)

Method Detail

handleEmissionback to summary
private void handleEmission(Function<S, Optional<O>> emission)
handleTransitionback to summary
private void handleTransition(Function<S, S> transition)
handleTransmissionback to summary
private void handleTransmission(Function<S, Tuple2<S, Optional<O>>> transmission)
observeInputsback to summary
protected Subscription observeInputs()

Implements abstract org.reactfx.ObservableBase.observeInputs.

Doc from org.reactfx.ObservableBase.observeInputs.

Starts observing this observable's input(s), if any. This method is called when the number of observers goes from 0 to 1. This method is called before newObserver(Object) is called for the first observer.

Annotations
@Override