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.
|
rx.internal.util | |
rx.observers |
Default wrappers and implementations for the base reactive consumer classes and interfaces;
utility classes for creating them from callbacks.
|
Modifier and Type | Method and Description |
---|---|
static <T> Notification<T> |
Notification.createOnCompleted()
Creates and returns a
Notification of variety Kind.OnCompleted . |
static <T> Notification<T> |
Notification.createOnCompleted(Class<T> type)
Deprecated.
this method does the same as
createOnCompleted() and does not use the passed in type hence it's useless. |
static <T> Notification<T> |
Notification.createOnError(Throwable e)
Creates and returns a
Notification of variety Kind.OnError , and assigns it an exception. |
static <T> Notification<T> |
Notification.createOnNext(T t)
Creates and returns a
Notification of variety Kind.OnNext , and assigns it a value. |
Modifier and Type | Method and Description |
---|---|
Observable<Notification<T>> |
Observable.materialize()
Returns an Observable that represents all of the emissions and notifications from the source
Observable into emissions marked with their original types within
Notification objects. |
Modifier and Type | Method and Description |
---|---|
Single<T> |
Single.doOnEach(Action1<Notification<? extends T>> onNotification)
|
Observable<T> |
Observable.doOnEach(Action1<Notification<? super T>> onNotification)
Modifies the source Observable so that it invokes an action for each item and terminal event it emits.
|
Completable |
Completable.doOnEach(Action1<Notification<Object>> onNotification)
Returns a Completable which calls the given onNotification callback when this Completable emits an error or completes.
|
Modifier and Type | Method and Description |
---|---|
Observable<? extends Notification<?>> |
OnSubscribeRedo.RetryWithPredicate.call(Observable<? extends Notification<?>> ts) |
Subscriber<? super Notification<T>> |
OperatorDematerialize.call(Subscriber<? super T> child) |
Modifier and Type | Method and Description |
---|---|
void |
BlockingOperatorToIterator.SubscriberIterator.onNext(Notification<? extends T> args) |
Modifier and Type | Method and Description |
---|---|
Observable<?> |
OnSubscribeRedo.RedoFinite.call(Observable<? extends Notification<?>> ts) |
Observable<? extends Notification<?>> |
OnSubscribeRedo.RetryWithPredicate.call(Observable<? extends Notification<?>> ts) |
Subscriber<? super T> |
OperatorMaterialize.call(Subscriber<? super Notification<T>> child) |
static <T> Observable<T> |
OnSubscribeRedo.redo(Observable<T> source,
Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler,
Scheduler scheduler) |
static <T> Observable<T> |
OnSubscribeRedo.repeat(Observable<T> source,
Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler) |
static <T> Observable<T> |
OnSubscribeRedo.repeat(Observable<T> source,
Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler,
Scheduler scheduler) |
static <T> Observable<T> |
OnSubscribeRedo.retry(Observable<T> source,
Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler) |
static <T> Observable<T> |
OnSubscribeRedo.retry(Observable<T> source,
Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler,
Scheduler scheduler) |
Modifier and Type | Method and Description |
---|---|
static Func1<Observable<? extends Notification<?>>,Observable<?>> |
InternalObservableUtils.createRepeatDematerializer(Func1<? super Observable<? extends Void>,? extends Observable<?>> notificationHandler)
Returns a function that dematerializes the notification signal from an Observable and calls
a notification handler with a null for non-terminal events.
|
static Func1<Observable<? extends Notification<?>>,Observable<?>> |
InternalObservableUtils.createRetryDematerializer(Func1<? super Observable<? extends Throwable>,? extends Observable<?>> notificationHandler)
Returns a function that dematerializes the notification signal from an Observable and calls
a notification handler with the Throwable.
|
Constructor and Description |
---|
ActionNotificationObserver(Action1<Notification<? super T>> onNotification) |
Modifier and Type | Method and Description |
---|---|
List<Notification<T>> |
TestObserver.getOnCompletedEvents()
Deprecated.
Get the
Notification s representing each time this observer was notified of sequence completion
via TestObserver.onCompleted() , as a List . |
List<Notification<T>> |
TestSubscriber.getOnCompletedEvents()
Deprecated.
use
TestSubscriber.getCompletions() instead. |
Copyright © 2018. All rights reserved.