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 final Notification<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 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

Fields in io.reactivex.rxjava3.internal.functions with type parameters of type Notification

Modifier and Type	Field	Description
(package private) final Consumer<? super Notification<T>>	Functions.NotificationOnComplete.onNotification
(package private) final Consumer<? super Notification<T>>	Functions.NotificationOnError.onNotification
(package private) final 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<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

Modifier	Constructor	Description
(package private)	NotificationOnComplete(Consumer<? super Notification<T>> onNotification)
(package private)	NotificationOnError(Consumer<? super Notification<T>> onNotification)
(package private)	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
(package private) static final class	BlockingFlowableLatest.LatestSubscriberIterator<T>	Subscriber of source, iterator for output.
(package private) static final class	BlockingFlowableNext.NextSubscriber<T>
final class	FlowableMaterialize<T>
(package private) static final class	FlowableMaterialize.MaterializeSubscriber<T>

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 final BlockingQueue<Notification<T>>	BlockingFlowableNext.NextSubscriber.buf
(package private) final Function<? super T, ? extends Notification<R>>	FlowableDematerialize.DematerializeSubscriber.selector
(package private) final Function<? super T, ? extends Notification<R>>	FlowableDematerialize.selector
(package private) final 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

Modifier	Constructor	Description
(package private)	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)
(package private)	MaterializeSubscriber(org.reactivestreams.Subscriber<? super Notification<T>> downstream)

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.

Fields in io.reactivex.rxjava3.internal.operators.maybe with type parameters of type Notification

Modifier and Type	Field	Description
(package private) final Function<? super T, Notification<R>>	MaybeDematerialize.DematerializeObserver.selector
(package private) final 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

Modifier	Constructor	Description
(package private)	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) final SingleObserver<? super Notification<T>>	MaterializeSingleObserver.downstream

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
(package private) static final class	BlockingObservableLatest.BlockingObservableLatestIterator<T>
(package private) static final class	BlockingObservableNext.NextObserver<T>
final class	ObservableMaterialize<T>

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 final BlockingQueue<Notification<T>>	BlockingObservableNext.NextObserver.buf
(package private) final Observer<? super Notification<T>>	ObservableMaterialize.MaterializeObserver.downstream
(package private) final Function<? super T, ? extends Notification<R>>	ObservableDematerialize.DematerializeObserver.selector
(package private) final Function<? super T, ? extends Notification<R>>	ObservableDematerialize.selector
(package private) final 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

Modifier	Constructor	Description
(package private)	DematerializeObserver(Observer<? super R> downstream, Function<? super T, ? extends Notification<R>> selector)
(package private)	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

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.

Fields in io.reactivex.rxjava3.internal.operators.single with type parameters of type Notification

Modifier and Type	Field	Description
(package private) final Function<? super T, Notification<R>>	SingleDematerialize.DematerializeObserver.selector
(package private) final 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

Modifier	Constructor	Description
(package private)	DematerializeObserver(MaybeObserver<? super R> downstream, Function<? super T, Notification<R>> selector)
	SingleDematerialize(Single<T> source, Function<? super T, Notification<R>> selector)