Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.operators.flowable |
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.
|
Modifier and Type | Method and Description |
---|---|
static <T> Flowable<T> |
Flowable.create(FlowableOnSubscribe<T> source,
BackpressureStrategy mode)
Provides an API (via a cold Flowable) that bridges the reactive world with the callback-style,
generally non-backpressured world.
|
Flowable<T> |
Observable.toFlowable(BackpressureStrategy strategy)
Converts the current Observable into a Flowable by applying the specified backpressure strategy.
|
Constructor and Description |
---|
FlowableCreate(FlowableOnSubscribe<T> source,
BackpressureStrategy backpressure) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.