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.