Uses of Class
com.github.davidmoten.rx.util.BackpressureStrategy

Packages that use BackpressureStrategy

Package	Description
com.github.davidmoten.rx
com.github.davidmoten.rx.internal.operators
com.github.davidmoten.rx.util

Uses of BackpressureStrategy in com.github.davidmoten.rx

Methods in com.github.davidmoten.rx with parameters of type BackpressureStrategy

Modifier and Type	Method and Description
StateMachine.Builder3<State,In,Out>	StateMachine.Builder3.backpressureStrategy(BackpressureStrategy backpressureStrategy)
static <State,In,Out> rx.Observable.Transformer<In,Out>	Transformers.stateMachine(rx.functions.Func0<State> initialStateFactory, rx.functions.Func3<? super State,? super In,? super rx.Subscriber<Out>,? extends State> transition, rx.functions.Func2<? super State,? super rx.Subscriber<Out>,Boolean> completion, BackpressureStrategy backpressureStrategy) Returns a Observable.Transformer that allows processing of the source stream to be defined in a state machine where transitions of the state machine may also emit items to downstream that are buffered if necessary when backpressure is requested.
static <State,In,Out> rx.Observable.Transformer<In,Out>	Transformers.stateMachine(rx.functions.Func0<State> initialStateFactory, rx.functions.Func3<? super State,? super In,? super rx.Subscriber<Out>,? extends State> transition, rx.functions.Func2<? super State,? super rx.Subscriber<Out>,Boolean> completion, BackpressureStrategy backpressureStrategy, int initialRequest)

Uses of BackpressureStrategy in com.github.davidmoten.rx.internal.operators

Methods in com.github.davidmoten.rx.internal.operators with parameters of type BackpressureStrategy

Modifier and Type	Method and Description
static <State,In,Out> rx.Observable.Transformer<In,Out>	TransformerStateMachine.create(rx.functions.Func0<? extends State> initialState, rx.functions.Func3<? super State,? super In,? super rx.Subscriber<Out>,? extends State> transition, rx.functions.Func2<? super State,? super rx.Subscriber<Out>,Boolean> completion, BackpressureStrategy backpressureStrategy, int initialRequest)

Uses of BackpressureStrategy in com.github.davidmoten.rx.util

Methods in com.github.davidmoten.rx.util that return BackpressureStrategy

Modifier and Type	Method and Description
static BackpressureStrategy	BackpressureStrategy.valueOf(String name) Returns the enum constant of this type with the specified name.
static BackpressureStrategy[]	BackpressureStrategy.values() Returns an array containing the constants of this enum type, in the order they are declared.