Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
rx.internal.operators |
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
|
Modifier and Type | Method and Description |
---|---|
static Emitter.BackpressureMode |
Emitter.BackpressureMode.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static Emitter.BackpressureMode[] |
Emitter.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.create(Action1<Emitter<T>> emitter,
Emitter.BackpressureMode backpressure)
Provides an API (via a cold Observable) that bridges the reactive world with the callback-style,
generally non-backpressured world.
|
Constructor and Description |
---|
OnSubscribeCreate(Action1<Emitter<T>> Emitter,
Emitter.BackpressureMode backpressure) |
Copyright © 2017. All rights reserved.