Class StatefulStreamBuilderOnImpl<S,O,I>

java.lang.Object

org.reactfx.StatefulStreamBuilderOnImpl<S,O,I>

All Implemented Interfaces:

StateMachine.StatefulStreamBuilderOn<S,O,I>

class StatefulStreamBuilderOnImpl<S,O,I>
extends Object
implements StateMachine.StatefulStreamBuilderOn<S,O,I>

Field Summary

Fields

Modifier and Type	Field	Description
private final LL<EmissionBuilder<S,O>>	emissions
private final S	initialState
private final EventStream<I>	input
private final LL<TransitionBuilder<S>>	transitions
private final LL<TransmissionBuilder<S,O>>	transmissions

Constructor Summary

Constructors

Constructor	Description
StatefulStreamBuilderOnImpl(S initialState, LL<TransitionBuilder<S>> transitions, LL<EmissionBuilder<S,O>> emissions, LL<TransmissionBuilder<S,O>> transmissions, EventStream<I> input)

Method Summary

Modifier and Type	Method	Description
StateMachine.StatefulStreamBuilder<S,O>	emit(BiFunction<? super S, ? super I, Optional<O>> f)
StateMachine.StatefulStreamBuilder<S,O>	transition(BiFunction<? super S, ? super I, ? extends S> f)
StateMachine.StatefulStreamBuilder<S,O>	transmit(BiFunction<? super S, ? super I, Tuple2<S, Optional<O>>> f)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

initialState

private final S initialState

transitions

private final LL<TransitionBuilder<S>> transitions

emissions

private final LL<EmissionBuilder<S,O>> emissions

transmissions

private final LL<TransmissionBuilder<S,O>> transmissions

input

private final EventStream<I> input

Constructor Details

StatefulStreamBuilderOnImpl

StatefulStreamBuilderOnImpl(S initialState,
 LL<TransitionBuilder<S>> transitions,
 LL<EmissionBuilder<S,O>> emissions,
 LL<TransmissionBuilder<S,O>> transmissions,
 EventStream<I> input)

Method Details

transition

public StateMachine.StatefulStreamBuilder<S,O> transition(BiFunction<? super S, ? super I, ? extends S> f)

Specified by:

transition in interface StateMachine.StatefulStreamBuilderOn<S,O,I>

emit

public StateMachine.StatefulStreamBuilder<S,O> emit(BiFunction<? super S, ? super I, Optional<O>> f)

Specified by:

emit in interface StateMachine.StatefulStreamBuilderOn<S,O,I>

transmit

public StateMachine.StatefulStreamBuilder<S,O> transmit(BiFunction<? super S, ? super I, Tuple2<S, Optional<O>>> f)

Specified by:

transmit in interface StateMachine.StatefulStreamBuilderOn<S,O,I>