Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
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)
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()
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 © 2020. All rights reserved.