Uses of Interface
com.github.davidmoten.rx2.StateMachine.Emitter

Packages that use StateMachine.Emitter

Package	Description
com.github.davidmoten.rx2
com.github.davidmoten.rx2.internal.flowable

Uses of StateMachine.Emitter in com.github.davidmoten.rx2

Methods in com.github.davidmoten.rx2 with parameters of type StateMachine.Emitter

Modifier and Type	Method and Description
void	StateMachine.Completion2.accept(State state, StateMachine.Emitter<Out> emitter)
void	StateMachine.Errored.accept(State state, Throwable error, StateMachine.Emitter<Out> emitter)
State	StateMachine.Transition2.apply(State state, In value, StateMachine.Emitter<Out> emitter)

Uses of StateMachine.Emitter in com.github.davidmoten.rx2.internal.flowable

Constructor parameters in com.github.davidmoten.rx2.internal.flowable with type arguments of type StateMachine.Emitter

Constructor and Description
FlowableStateMachine(io.reactivex.Flowable<In> source, Callable<? extends State> initialState, io.reactivex.functions.Function3<? super State,? super In,? super StateMachine.Emitter<Out>,? extends State> transition, io.reactivex.functions.BiConsumer<? super State,? super StateMachine.Emitter<Out>> completionAction, Consumer3<? super State,? super Throwable,? super StateMachine.Emitter<Out>> errorAction, io.reactivex.BackpressureStrategy backpressureStrategy, int requestBatchSize)
FlowableStateMachine(io.reactivex.Flowable<In> source, Callable<? extends State> initialState, io.reactivex.functions.Function3<? super State,? super In,? super StateMachine.Emitter<Out>,? extends State> transition, io.reactivex.functions.BiConsumer<? super State,? super StateMachine.Emitter<Out>> completionAction, Consumer3<? super State,? super Throwable,? super StateMachine.Emitter<Out>> errorAction, io.reactivex.BackpressureStrategy backpressureStrategy, int requestBatchSize)
FlowableStateMachine(io.reactivex.Flowable<In> source, Callable<? extends State> initialState, io.reactivex.functions.Function3<? super State,? super In,? super StateMachine.Emitter<Out>,? extends State> transition, io.reactivex.functions.BiConsumer<? super State,? super StateMachine.Emitter<Out>> completionAction, Consumer3<? super State,? super Throwable,? super StateMachine.Emitter<Out>> errorAction, io.reactivex.BackpressureStrategy backpressureStrategy, int requestBatchSize)