Uses of Class
io.reactivex.rxjava3.core.Notification
-
Packages that use Notification Package Description io.reactivex.rxjava3.core Base reactive classes:Flowable
,Observable
,Single
,Maybe
andCompletable
; base reactive consumers; other common base interfaces.io.reactivex.rxjava3.internal.functions io.reactivex.rxjava3.internal.operators.completable io.reactivex.rxjava3.internal.operators.flowable io.reactivex.rxjava3.internal.operators.maybe io.reactivex.rxjava3.internal.operators.mixed io.reactivex.rxjava3.internal.operators.observable io.reactivex.rxjava3.internal.operators.single -
-
Uses of Notification in io.reactivex.rxjava3.core
Fields in io.reactivex.rxjava3.core declared as Notification Modifier and Type Field Description (package private) static Notification<java.lang.Object>
Notification. COMPLETE
The singleton instance for createOnComplete.Methods in io.reactivex.rxjava3.core that return Notification Modifier and Type Method Description static <T> @NonNull Notification<T>
Notification. createOnComplete()
Returns the empty and stateless shared instance of a notification representing anonComplete
signal.static <T> @NonNull Notification<T>
Notification. createOnError(@NonNull java.lang.Throwable error)
Constructs an onError notification containing the error.static <@NonNull T>
@NonNull Notification<T>Notification. createOnNext(@NonNull T value)
Constructs an onNext notification containing the given value.Methods in io.reactivex.rxjava3.core that return types with arguments of type Notification Modifier and Type Method Description <@NonNull T>
@NonNull Single<Notification<T>>Completable. materialize()
Maps the signal types of thisCompletable
into aNotification
of the same kind and emits it as a single success value to downstream.@NonNull Flowable<Notification<T>>
Flowable. materialize()
Returns aFlowable
that represents all of the emissions and notifications from the currentFlowable
into emissions marked with their original types withinNotification
objects.@NonNull Single<Notification<T>>
Maybe. materialize()
Maps the signal types of thisMaybe
into aNotification
of the same kind and emits it as aSingle
'sonSuccess
value to downstream.@NonNull Observable<Notification<T>>
Observable. materialize()
Returns anObservable
that represents all of the emissions and notifications from the currentObservable
into emissions marked with their original types withinNotification
objects.@NonNull Single<Notification<T>>
Single. materialize()
Maps the signal types of thisSingle
into aNotification
of the same kind and emits it as a single success value to downstream.Method parameters in io.reactivex.rxjava3.core with type arguments of type Notification Modifier and Type Method Description <@NonNull R>
@NonNull Flowable<R>Flowable. dematerialize(@NonNull Function<? super @NonNull T,@NonNull Notification<@NonNull R>> selector)
Returns aFlowable
that reverses the effect ofmaterialize
by transforming theNotification
objects extracted from the source items via a selector function into their respectiveSubscriber
signal types.<@NonNull R>
@NonNull Maybe<R>Maybe. dematerialize(@NonNull Function<? super @NonNull T,@NonNull Notification<@NonNull R>> selector)
Maps theNotification
success value of the currentMaybe
back into normalonSuccess
,onError
oronComplete
signals.<@NonNull R>
@NonNull Observable<R>Observable. dematerialize(@NonNull Function<? super @NonNull T,Notification<@NonNull R>> selector)
Returns anObservable
that reverses the effect ofmaterialize
by transforming theNotification
objects extracted from the source items via a selector function into their respectiveObserver
signal types.<@NonNull R>
@NonNull Maybe<R>Single. dematerialize(@NonNull Function<? super @NonNull T,@NonNull Notification<@NonNull R>> selector)
Maps theNotification
success value of the currentSingle
back into normalonSuccess
,onError
oronComplete
signals as aMaybe
source.@NonNull Flowable<T>
Flowable. doOnEach(@NonNull Consumer<? super Notification<@NonNull T>> onNotification)
Invokes aConsumer
with aNotification
instances matching the signals emitted by the currentFlowable
before they are forwarded to the downstream.@NonNull Observable<T>
Observable. doOnEach(@NonNull Consumer<? super Notification<@NonNull T>> onNotification)
Returns anObservable
that invokes aConsumer
with the appropriateNotification
object when the currentObservable
signals an item or terminates. -
Uses of Notification in io.reactivex.rxjava3.internal.functions
Fields in io.reactivex.rxjava3.internal.functions with type parameters of type Notification Modifier and Type Field Description (package private) Consumer<? super Notification<T>>
Functions.NotificationOnComplete. onNotification
(package private) Consumer<? super Notification<T>>
Functions.NotificationOnError. onNotification
(package private) Consumer<? super Notification<T>>
Functions.NotificationOnNext. onNotification
Method parameters in io.reactivex.rxjava3.internal.functions with type arguments of type Notification Modifier and Type Method Description static <T> Action
Functions. notificationOnComplete(Consumer<? super Notification<T>> onNotification)
static <T> Consumer<java.lang.Throwable>
Functions. notificationOnError(Consumer<? super Notification<T>> onNotification)
static <T> Consumer<T>
Functions. notificationOnNext(Consumer<? super Notification<T>> onNotification)
Constructor parameters in io.reactivex.rxjava3.internal.functions with type arguments of type Notification Constructor Description NotificationOnComplete(Consumer<? super Notification<T>> onNotification)
NotificationOnError(Consumer<? super Notification<T>> onNotification)
NotificationOnNext(Consumer<? super Notification<T>> onNotification)
-
Uses of Notification in io.reactivex.rxjava3.internal.operators.completable
Method parameters in io.reactivex.rxjava3.internal.operators.completable with type arguments of type Notification Modifier and Type Method Description protected void
CompletableMaterialize. subscribeActual(SingleObserver<? super Notification<T>> observer)
-
Uses of Notification in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as Notification Modifier and Type Field Description (package private) Notification<T>
BlockingFlowableLatest.LatestSubscriberIterator. iteratorNotification
Fields in io.reactivex.rxjava3.internal.operators.flowable with type parameters of type Notification Modifier and Type Field Description private java.util.concurrent.BlockingQueue<Notification<T>>
BlockingFlowableNext.NextSubscriber. buf
(package private) Function<? super T,? extends Notification<R>>
FlowableDematerialize.DematerializeSubscriber. selector
(package private) Function<? super T,? extends Notification<R>>
FlowableDematerialize. selector
(package private) java.util.concurrent.atomic.AtomicReference<Notification<T>>
BlockingFlowableLatest.LatestSubscriberIterator. value
Methods in io.reactivex.rxjava3.internal.operators.flowable that return Notification Modifier and Type Method Description Notification<T>
BlockingFlowableNext.NextSubscriber. takeNext()
Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type Notification Modifier and Type Method Description protected void
FlowableMaterialize.MaterializeSubscriber. onDrop(Notification<T> n)
void
BlockingFlowableLatest.LatestSubscriberIterator. onNext(Notification<T> args)
void
BlockingFlowableNext.NextSubscriber. onNext(Notification<T> args)
Method parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type Notification Modifier and Type Method Description protected void
FlowableMaterialize. subscribeActual(org.reactivestreams.Subscriber<? super Notification<T>> s)
Constructor parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type Notification Constructor Description DematerializeSubscriber(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T,? extends Notification<R>> selector)
FlowableDematerialize(Flowable<T> source, Function<? super T,? extends Notification<R>> selector)
MaterializeSubscriber(org.reactivestreams.Subscriber<? super Notification<T>> downstream)
-
Uses of Notification in io.reactivex.rxjava3.internal.operators.maybe
Fields in io.reactivex.rxjava3.internal.operators.maybe with type parameters of type Notification Modifier and Type Field Description (package private) Function<? super T,Notification<R>>
MaybeDematerialize.DematerializeObserver. selector
(package private) Function<? super T,Notification<R>>
MaybeDematerialize. selector
Method parameters in io.reactivex.rxjava3.internal.operators.maybe with type arguments of type Notification Modifier and Type Method Description protected void
MaybeMaterialize. subscribeActual(SingleObserver<? super Notification<T>> observer)
Constructor parameters in io.reactivex.rxjava3.internal.operators.maybe with type arguments of type Notification Constructor Description DematerializeObserver(MaybeObserver<? super R> downstream, Function<? super T,Notification<R>> selector)
MaybeDematerialize(Maybe<T> source, Function<? super T,Notification<R>> selector)
-
Uses of Notification in io.reactivex.rxjava3.internal.operators.mixed
Fields in io.reactivex.rxjava3.internal.operators.mixed with type parameters of type Notification Modifier and Type Field Description (package private) SingleObserver<? super Notification<T>>
MaterializeSingleObserver. downstream
Constructor parameters in io.reactivex.rxjava3.internal.operators.mixed with type arguments of type Notification Constructor Description MaterializeSingleObserver(SingleObserver<? super Notification<T>> downstream)
-
Uses of Notification in io.reactivex.rxjava3.internal.operators.observable
Fields in io.reactivex.rxjava3.internal.operators.observable declared as Notification Modifier and Type Field Description (package private) Notification<T>
BlockingObservableLatest.BlockingObservableLatestIterator. iteratorNotification
Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type Notification Modifier and Type Field Description private java.util.concurrent.BlockingQueue<Notification<T>>
BlockingObservableNext.NextObserver. buf
(package private) Observer<? super Notification<T>>
ObservableMaterialize.MaterializeObserver. downstream
(package private) Function<? super T,? extends Notification<R>>
ObservableDematerialize.DematerializeObserver. selector
(package private) Function<? super T,? extends Notification<R>>
ObservableDematerialize. selector
(package private) java.util.concurrent.atomic.AtomicReference<Notification<T>>
BlockingObservableLatest.BlockingObservableLatestIterator. value
Methods in io.reactivex.rxjava3.internal.operators.observable that return Notification Modifier and Type Method Description Notification<T>
BlockingObservableNext.NextObserver. takeNext()
Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type Notification Modifier and Type Method Description void
BlockingObservableLatest.BlockingObservableLatestIterator. onNext(Notification<T> args)
void
BlockingObservableNext.NextObserver. onNext(Notification<T> args)
Method parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type Notification Modifier and Type Method Description void
ObservableMaterialize. subscribeActual(Observer<? super Notification<T>> t)
Constructor parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type Notification Constructor Description DematerializeObserver(Observer<? super R> downstream, Function<? super T,? extends Notification<R>> selector)
MaterializeObserver(Observer<? super Notification<T>> downstream)
ObservableDematerialize(ObservableSource<T> source, Function<? super T,? extends Notification<R>> selector)
-
Uses of Notification in io.reactivex.rxjava3.internal.operators.single
Fields in io.reactivex.rxjava3.internal.operators.single with type parameters of type Notification Modifier and Type Field Description (package private) Function<? super T,Notification<R>>
SingleDematerialize.DematerializeObserver. selector
(package private) Function<? super T,Notification<R>>
SingleDematerialize. selector
Method parameters in io.reactivex.rxjava3.internal.operators.single with type arguments of type Notification Modifier and Type Method Description protected void
SingleMaterialize. subscribeActual(SingleObserver<? super Notification<T>> observer)
Constructor parameters in io.reactivex.rxjava3.internal.operators.single with type arguments of type Notification Constructor Description DematerializeObserver(MaybeObserver<? super R> downstream, Function<? super T,Notification<R>> selector)
SingleDematerialize(Single<T> source, Function<? super T,Notification<R>> selector)
-