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

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 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
final <@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.
final @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.
final @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.
final @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.
final @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
final <@NonNull R> @NonNull Flowable<R>	Flowable.dematerialize(@NonNull Function<@NonNull ? 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.
final <@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.
final <@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.
final <@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.
final @NonNull Flowable<T>	Flowable.doOnEach(@NonNull Consumer<@NonNull ? 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.
final @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

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<Throwable>	Functions.notificationOnError(Consumer<? super Notification<T>> onNotification)
static <T> Consumer<T>	Functions.notificationOnNext(Consumer<? super Notification<T>> onNotification)

Uses of Notification in io.reactivex.rxjava3.internal.operators.completable

Subclasses with type arguments of type Notification in io.reactivex.rxjava3.internal.operators.completable

Modifier and Type	Class	Description
final class	CompletableMaterialize<T>	Turn the signal types of a Completable source into a single Notification of equal kind.

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

Subclasses with type arguments of type Notification in io.reactivex.rxjava3.internal.operators.flowable

Modifier and Type	Class	Description
final class	FlowableMaterialize<T>

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

Modifier	Constructor	Description
	FlowableDematerialize(Flowable<T> source, Function<? super T, ? extends Notification<R>> selector)

Uses of Notification in io.reactivex.rxjava3.internal.operators.maybe

Subclasses with type arguments of type Notification in io.reactivex.rxjava3.internal.operators.maybe

Modifier and Type	Class	Description
final class	MaybeMaterialize<T>	Turn the signal types of a Maybe source into a single Notification of equal kind.

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

Modifier	Constructor	Description
	MaybeDematerialize(Maybe<T> source, Function<? super T, Notification<R>> selector)

Uses of Notification in io.reactivex.rxjava3.internal.operators.mixed

Constructor parameters in io.reactivex.rxjava3.internal.operators.mixed with type arguments of type Notification

Modifier	Constructor	Description
	MaterializeSingleObserver(SingleObserver<? super Notification<T>> downstream)

Uses of Notification in io.reactivex.rxjava3.internal.operators.observable

Subclasses with type arguments of type Notification in io.reactivex.rxjava3.internal.operators.observable

Modifier and Type	Class	Description
final class	ObservableMaterialize<T>

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

Modifier	Constructor	Description
	ObservableDematerialize(ObservableSource<T> source, Function<? super T, ? extends Notification<R>> selector)

Uses of Notification in io.reactivex.rxjava3.internal.operators.single

Subclasses with type arguments of type Notification in io.reactivex.rxjava3.internal.operators.single

Modifier and Type	Class	Description
final class	SingleMaterialize<T>	Turn the signal types of a Single source into a single Notification of equal kind.

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

Modifier	Constructor	Description
	SingleDematerialize(Single<T> source, Function<? super T, Notification<R>> selector)