| 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>> |
TestSubscriber.getOnCompletedEvents()
Deprecated.
use
TestSubscriber.getCompletions() instead. |
List<Notification<T>> |
TestObserver.getOnCompletedEvents()
Deprecated.
Get the
Notifications representing each time this observer was notified of sequence completion
via TestObserver.onCompleted(), as a List. |
Copyright © 2025. All rights reserved.