| Package | Description |
|---|---|
| rx |
Rx Observables
|
| rx.functions | |
| rx.internal.operators |
Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
|
| rx.internal.schedulers | |
| rx.observers | |
| rx.plugins | |
| rx.subscriptions |
| Modifier and Type | Method and Description |
|---|---|
Observable |
Observable.doOnCompleted(Action0
Modifies the source Observable so that it invokes an action when it calls
onCompleted.
|
Observable |
Observable.doOnSubscribe(Action0
Modifies the source
Observable so that it invokes the given action when it is subscribed from its subscribers.
|
Observable |
Observable.doOnTerminate(Action0
Modifies the source Observable so that it invokes an action when it calls
onCompleted or
onError.
|
Observable |
Observable.doOnUnsubscribe(Action0
Modifies the source
Observable so that it invokes the given action when it is unsubscribed from its subscribers.
|
Observable |
Observable.finallyDo(Action0
|
void |
Observable.forEach(Action1
Subscribes to the
Observable and receives notifications for each element and the terminal events.
|
abstract Subscription |
Scheduler.Worker.schedule(Action0
Schedules an Action for execution.
|
abstract Subscription |
Scheduler.Worker.schedule(Action0
Schedules an Action for execution at some point in the future.
|
Subscription |
Scheduler.Worker.schedulePeriodically(Action0
Schedules a cancelable action to be executed periodically.
|
Subscription |
Observable.subscribe(Action1
Subscribes to an Observable and provides callbacks to handle the items it emits and any error or completion notification it issues.
|
| Modifier and Type | Method and Description |
|---|---|
static FuncN |
Functions.fromAction(Action0
|
static Func0 |
Actions.toFunc(Action0
Converts an
Action0 to a function that calls the action and returns
null.
|
static <R> Func0 |
Actions.toFunc(Action0
Converts an
Action0 to a function that calls the action and returns a specified value.
|
| Constructor and Description | |
|---|---|
OperatorDoOnSubscribe(Action0
Constructs an instance of the operator with the callback that gets invoked when the modified Observable is subscribed
|
|
OperatorDoOnUnsubscribe(Action0
Constructs an instance of the operator with the callback that gets invoked when the modified Observable is unsubscribed
|
|
OperatorFinally(Action0
|
| Modifier and Type | Method and Description |
|---|---|
Subscription |
NewThreadWorker.schedule(Action0
|
Subscription |
NewThreadWorker.schedule(Action0
|
ScheduledAction |
NewThreadWorker.scheduleActual(Action0
|
| Constructor and Description | |
|---|---|
ScheduledAction(Action0
|
| Modifier and Type | Method and Description |
|---|---|
static <T> Subscriber |
Subscribers.create(Action1
Creates an
Subscriber that receives the emissions of any
Observable it subscribes to via
onNext and handles any
onError or
onCompleted notifications.
|
static <T> Observer |
Observers.create(Action1
Creates an
Observer that receives the emissions of any
Observable it subscribes to via
onNext and handles any
onError or
onCompleted notifications.
|
| Modifier and Type | Method and Description |
|---|---|
Action0 |
RxJavaSchedulersHook.onSchedule(Action0
Invoked before the Action is handed over to the scheduler.
|
| Modifier and Type | Method and Description |
|---|---|
Action0 |
RxJavaSchedulersHook.onSchedule(Action0
Invoked before the Action is handed over to the scheduler.
|
| Modifier and Type | Method and Description |
|---|---|
static Subscription |
Subscriptions.create(Action0
Creates and returns a
Subscription that invokes the given
Action0 when unsubscribed.
|
static BooleanSubscription |
BooleanSubscription.create(Action0
Creates a
BooleanSubscription with a specified function to invoke upon unsubscribe.
|