Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
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 © 2022. All rights reserved.