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 and Completable; 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 an onComplete 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 this Completable into a Notification of the same kind and emits it as a single success value to downstream.
@NonNull Flowable<Notification<T>>	Flowable.materialize()	Returns a Flowable that represents all of the emissions and notifications from the current Flowable into emissions marked with their original types within Notification objects.
@NonNull 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's onSuccess value to downstream.
@NonNull Observable<Notification<T>>	Observable.materialize()	Returns an Observable that represents all of the emissions and notifications from the current Observable into emissions marked with their original types within Notification objects.
@NonNull 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.

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 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.
<@NonNull R> @NonNull Maybe<R>	Maybe.dematerialize(@NonNull Function<? super @NonNull T,@NonNull Notification<@NonNull R>> selector)	Maps the Notification success value of the current Maybe back into normal onSuccess, onError or onComplete signals.
<@NonNull R> @NonNull Observable<R>	Observable.dematerialize(@NonNull Function<? super @NonNull T,Notification<@NonNull 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.
<@NonNull R> @NonNull Maybe<R>	Single.dematerialize(@NonNull Function<? super @NonNull T,@NonNull Notification<@NonNull R>> selector)	Maps the Notification success value of the current Single back into normal onSuccess, onError or onComplete signals as a Maybe source.
@NonNull Flowable<T>	Flowable.doOnEach(@NonNull Consumer<? super Notification<@NonNull T>> onNotification)	Invokes a Consumer with a Notification instances matching the signals emitted by the current Flowable before they are forwarded to the downstream.
@NonNull Observable<T>	Observable.doOnEach(@NonNull Consumer<? super Notification<@NonNull T>> onNotification)	Returns an Observable that invokes a Consumer with the appropriate Notification object when the current Observable 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)