Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
Modifier and Type | Method and Description |
---|---|
static AsyncEmitter.BackpressureMode |
AsyncEmitter.BackpressureMode.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static AsyncEmitter.BackpressureMode[] |
AsyncEmitter.BackpressureMode.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> Observable<T> |
Observable.fromAsync(Action1<AsyncEmitter<T>> asyncEmitter,
AsyncEmitter.BackpressureMode backpressure)
Provides an API (via a cold Observable) that bridges the reactive world with the callback-style,
generally non-backpressured world.
|
Copyright © 2023. All rights reserved.