Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
rx.exceptions |
Exception handling utilities, safe subscriber exception classes,
lifecycle exception classes.
|
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 |
---|---|
Subscription |
Single.subscribe(SingleSubscriber<? super T> te)
Subscribes to a Single and provides a
SingleSubscriber that implements functions to handle the
item the Single emits or any error notification it issues. |
Modifier and Type | Method and Description |
---|---|
static void |
Exceptions.throwOrReport(Throwable throwable,
SingleSubscriber<?> subscriber)
Forwards a fatal exception or reports it to the given Observer.
|
static void |
Exceptions.throwOrReport(Throwable t,
SingleSubscriber<?> o,
Object value)
Forwards a fatal exception or reports it along with the value
caused it to the given SingleSubscriber.
|
Modifier and Type | Method and Description |
---|---|
static <T> SingleSubscriber<T> |
SingleLiftObservableOperator.wrap(Subscriber<T> subscriber) |
Modifier and Type | Method and Description |
---|---|
void |
SingleLiftObservableOperator.call(SingleSubscriber<? super R> t) |
void |
SingleOnSubscribeMap.call(SingleSubscriber<? super R> o) |
void |
SingleDoAfterTerminate.call(SingleSubscriber<? super T> t) |
void |
SingleFromObservable.call(SingleSubscriber<? super T> t) |
void |
SingleDoOnSubscribe.call(SingleSubscriber<? super T> t) |
void |
OnSubscribeSingle.call(SingleSubscriber<? super T> child) |
void |
OnSubscribeOnAssemblySingle.call(SingleSubscriber<? super T> t) |
void |
SingleObserveOn.call(SingleSubscriber<? super T> t) |
void |
SingleOnSubscribeDelaySubscriptionOther.call(SingleSubscriber<? super T> subscriber) |
void |
SingleDoOnEvent.call(SingleSubscriber<? super T> actual) |
void |
SingleTimeout.call(SingleSubscriber<? super T> t) |
void |
SingleTakeUntilObservable.call(SingleSubscriber<? super T> t) |
void |
SingleOnSubscribeUsing.call(SingleSubscriber<? super T> child) |
void |
SingleTakeUntilCompletable.call(SingleSubscriber<? super T> t) |
void |
SingleOperatorOnErrorResumeNext.call(SingleSubscriber<? super T> child) |
void |
SingleFromCallable.call(SingleSubscriber<? super T> t) |
void |
SingleDelay.call(SingleSubscriber<? super T> t) |
void |
SingleFromEmitter.call(SingleSubscriber<? super T> t) |
void |
SingleOnErrorReturn.call(SingleSubscriber<? super T> t) |
void |
SingleFromFuture.call(SingleSubscriber<? super T> t) |
void |
SingleDoOnUnsubscribe.call(SingleSubscriber<? super T> t) |
void |
SingleTakeUntilSingle.call(SingleSubscriber<? super T> t) |
Copyright © 2018. All rights reserved.