Package | Description |
---|---|
rx |
Rx Observables
|
rx.functions | |
rx.observers | |
rx.plugins | |
rx.subscriptions |
Modifier and Type | Method and Description |
---|---|
Observable<T> |
Observable.doOnCompleted(Action0 onCompleted)
Modifies the source Observable so that it invokes an action when it calls
onCompleted . |
Observable<T> |
Observable.doOnSubscribe(Action0 subscribe)
Modifies the source
Observable so that it invokes the given action when it is subscribed from
its subscribers. |
Observable<T> |
Observable.doOnTerminate(Action0 onTerminate)
Modifies the source Observable so that it invokes an action when it calls
onCompleted or
onError . |
Observable<T> |
Observable.doOnUnsubscribe(Action0 unsubscribe)
Modifies the source
Observable so that it invokes the given action when it is unsubscribed from
its subscribers. |
Observable<T> |
Observable.finallyDo(Action0 action)
|
void |
Observable.forEach(Action1<? super T> onNext,
Action1<Throwable> onError,
Action0 onComplete)
Subscribes to the
Observable and receives notifications for each element and the terminal events. |
Observable<T> |
Observable.onBackpressureBuffer(long capacity,
Action0 onOverflow)
Instructs an Observable that is emitting items faster than its observer can consume them to buffer up to
a given amount of items until they can be emitted.
|
abstract Subscription |
Scheduler.Worker.schedule(Action0 action)
Schedules an Action for execution.
|
abstract Subscription |
Scheduler.Worker.schedule(Action0 action,
long delayTime,
TimeUnit unit)
Schedules an Action for execution at some point in the future.
|
Subscription |
Scheduler.Worker.schedulePeriodically(Action0 action,
long initialDelay,
long period,
TimeUnit unit)
Schedules a cancelable action to be executed periodically.
|
Subscription |
Observable.subscribe(Action1<? super T> onNext,
Action1<Throwable> onError,
Action0 onComplete)
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<Void> |
Functions.fromAction(Action0 f)
|
static Func0<Void> |
Actions.toFunc(Action0 action)
Converts an
Action0 to a function that calls the action and returns null . |
static <R> Func0<R> |
Actions.toFunc(Action0 action,
R result)
Converts an
Action0 to a function that calls the action and returns a specified value. |
Modifier and Type | Method and Description |
---|---|
static <T> Subscriber<T> |
Subscribers.create(Action1<? super T> onNext,
Action1<Throwable> onError,
Action0 onComplete)
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<T> |
Observers.create(Action1<? super T> onNext,
Action1<Throwable> onError,
Action0 onComplete)
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 action)
Invoked before the Action is handed over to the scheduler.
|
Modifier and Type | Method and Description |
---|---|
Action0 |
RxJavaSchedulersHook.onSchedule(Action0 action)
Invoked before the Action is handed over to the scheduler.
|
Modifier and Type | Method and Description |
---|---|
static Subscription |
Subscriptions.create(Action0 unsubscribe)
Creates and returns a
Subscription that invokes the given Action0 when unsubscribed. |
static BooleanSubscription |
BooleanSubscription.create(Action0 onUnsubscribe)
Creates a
BooleanSubscription with a specified function to invoke upon unsubscribe. |
Copyright © 2015. All Rights Reserved.