| Package | Description |
|---|---|
| com.github.davidmoten.rx2 | |
| com.github.davidmoten.rx2.internal.flowable |
| Modifier and Type | Interface and Description |
|---|---|
static interface |
StateMachine.Errored<State,Out> |
| 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) |
Copyright © 2013–2020. All rights reserved.