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
Notification s representing each time this observer was notified of sequence completion
via TestObserver.onCompleted() , as a List . |
List<Notification<T>> |
TestSubscriber.getOnCompletedEvents()
Returns the
Notification s representing each time this Subscriber was notified of sequence
completion via TestSubscriber.onCompleted() , as a List . |
Copyright © 2015. All Rights Reserved.