Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.functions | |
io.reactivex.internal.operators.flowable | |
io.reactivex.internal.operators.observable |
Modifier and Type | Method and Description |
---|---|
static <T> Notification<T> |
Notification.createOnComplete()
Returns the empty and stateless shared instance of a notification representing
an onComplete signal.
|
static <T> Notification<T> |
Notification.createOnError(Throwable error)
Constructs an onError notification containing the error.
|
static <T> Notification<T> |
Notification.createOnNext(T value)
Constructs an onNext notification containing the given value.
|
Modifier and Type | Method and Description |
---|---|
Flowable<Notification<T>> |
Flowable.materialize()
Returns a Flowable that represents all of the emissions and notifications from the source
Publisher into emissions marked with their original types within
Notification objects. |
Observable<Notification<T>> |
Observable.materialize()
Returns an Observable that represents all of the emissions and notifications from the source
ObservableSource into emissions marked with their original types within
Notification objects. |
Modifier and Type | Method and Description |
---|---|
Flowable<T> |
Flowable.doOnEach(Consumer<? super Notification<T>> onNotification)
Modifies the source Publisher so that it invokes an action for each item it emits.
|
Observable<T> |
Observable.doOnEach(Consumer<? super Notification<T>> onNotification)
Modifies the source ObservableSource so that it invokes an action for each item it emits.
|
Modifier and Type | Method and Description |
---|---|
static <T> Action |
Functions.notificationOnComplete(Consumer<? super Notification<T>> onNotification) |
static <T> Consumer<Throwable> |
Functions.notificationOnError(Consumer<? super Notification<T>> onNotification) |
static <T> Consumer<T> |
Functions.notificationOnNext(Consumer<? super Notification<T>> onNotification) |
Modifier and Type | Method and Description |
---|---|
protected void |
FlowableMaterialize.subscribeActual(org.reactivestreams.Subscriber<? super Notification<T>> s) |
Constructor and Description |
---|
FlowableDematerialize(Flowable<Notification<T>> source) |
Modifier and Type | Method and Description |
---|---|
void |
ObservableMaterialize.subscribeActual(Observer<? super Notification<T>> t) |
Constructor and Description |
---|
ObservableDematerialize(ObservableSource<Notification<T>> source) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.