| Package | Description |
|---|---|
| rx |
Rx Observables
|
| rx.observers |
| 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)
Creates and returns a
Notification of variety Kind.OnCompleted. |
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 |
|---|---|
Observable<T> |
Observable.doOnEach(Action1<Notification<? super T>> onNotification)
Modifies the source Observable so that it invokes an action for each item it emits.
|
| Modifier and Type | Method and Description |
|---|---|
List<Notification<T>> |
TestObserver.getOnCompletedEvents()
Get the
Notifications representing each time this observer was notified of sequence completion
via TestObserver.onCompleted(), as a List. |
List<Notification<T>> |
TestSubscriber.getOnCompletedEvents()
Returns the
Notifications representing each time this Subscriber was notified of sequence
completion via TestSubscriber.onCompleted(), as a List. |
Copyright © 2016. All rights reserved.