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.completable | |
io.reactivex.internal.operators.flowable | |
io.reactivex.internal.operators.maybe | |
io.reactivex.internal.operators.mixed | |
io.reactivex.internal.operators.observable | |
io.reactivex.internal.operators.single |
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 |
---|---|
Single<Notification<T>> |
Single.materialize()
Maps the signal types of this Single into a
Notification of the same kind
and emits it as a single success value to downstream. |
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. |
Single<Notification<T>> |
Maybe.materialize()
Maps the signal types of this Maybe into a
Notification of the same kind
and emits it as a single success value to downstream. |
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. |
<T> Single<Notification<T>> |
Completable.materialize()
Maps the signal types of this Completable into a
Notification of the same kind
and emits it as a single success value to downstream. |
Modifier and Type | Method and Description |
---|---|
<R> Maybe<R> |
Single.dematerialize(Function<? super T,Notification<R>> selector)
Maps the
Notification success value of this Single back into normal
onSuccess , onError or onComplete signals as a
Maybe source. |
<R> Observable<R> |
Observable.dematerialize(Function<? super T,Notification<R>> selector)
Returns an Observable that reverses the effect of
materialize by transforming the
Notification objects extracted from the source items via a selector function
into their respective Observer signal types. |
<R> Flowable<R> |
Flowable.dematerialize(Function<? super T,Notification<R>> selector)
Returns a Flowable that reverses the effect of
materialize by transforming the
Notification objects extracted from the source items via a selector function
into their respective Subscriber signal types. |
Observable<T> |
Observable.doOnEach(Consumer<? super Notification<T>> onNotification)
Modifies the source ObservableSource so that it invokes an action for each item it emits.
|
Flowable<T> |
Flowable.doOnEach(Consumer<? super Notification<T>> onNotification)
Modifies the source Publisher 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 |
CompletableMaterialize.subscribeActual(SingleObserver<? super Notification<T>> observer) |
Modifier and Type | Method and Description |
---|---|
protected void |
FlowableMaterialize.subscribeActual(org.reactivestreams.Subscriber<? super Notification<T>> s) |
Constructor and Description |
---|
FlowableDematerialize(Flowable<T> source,
Function<? super T,? extends Notification<R>> selector) |
Modifier and Type | Method and Description |
---|---|
protected void |
MaybeMaterialize.subscribeActual(SingleObserver<? super Notification<T>> observer) |
Constructor and Description |
---|
MaterializeSingleObserver(SingleObserver<? super Notification<T>> downstream) |
Modifier and Type | Method and Description |
---|---|
void |
ObservableMaterialize.subscribeActual(Observer<? super Notification<T>> t) |
Constructor and Description |
---|
ObservableDematerialize(ObservableSource<T> source,
Function<? super T,? extends Notification<R>> selector) |
Modifier and Type | Method and Description |
---|---|
protected void |
SingleMaterialize.subscribeActual(SingleObserver<? super Notification<T>> observer) |
Constructor and Description |
---|
SingleDematerialize(Single<T> source,
Function<? super T,Notification<R>> selector) |
Copyright © 2019. All rights reserved.