Uses of Class
io.reactivex.rxjava3.core.Notification
Packages that use Notification
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.-
Uses of Notification in io.reactivex.rxjava3.core
Fields in io.reactivex.rxjava3.core declared as NotificationModifier and TypeFieldDescription(package private) static final Notification
<Object> Notification.COMPLETE
The singleton instance for createOnComplete.Methods in io.reactivex.rxjava3.core that return NotificationModifier and TypeMethodDescriptionstatic <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 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 NotificationModifier and TypeMethodDescriptionfinal <@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.final @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.final @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.final @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.final @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 NotificationModifier and TypeMethodDescriptionFlowable.dematerialize
(@NonNull Function<@NonNull ? 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.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.final <@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.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.Invokes aConsumer
with aNotification
instances matching the signals emitted by the currentFlowable
before they are forwarded to the downstream.final @NonNull Observable
<T> 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 NotificationModifier and TypeFieldDescription(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 NotificationModifier and TypeMethodDescriptionstatic <T> Action
Functions.notificationOnComplete
(Consumer<? super Notification<T>> onNotification) 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 NotificationModifierConstructorDescription(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
Method parameters in io.reactivex.rxjava3.internal.operators.completable with type arguments of type NotificationModifier and TypeMethodDescriptionprotected 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 NotificationModifier and TypeFieldDescription(package private) Notification
<T> BlockingFlowableLatest.LatestSubscriberIterator.iteratorNotification
Fields in io.reactivex.rxjava3.internal.operators.flowable with type parameters of type NotificationModifier and TypeFieldDescriptionprivate 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 NotificationMethods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type NotificationModifier and TypeMethodDescriptionprotected 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 NotificationModifier and TypeMethodDescriptionprotected void
FlowableMaterialize.subscribeActual
(org.reactivestreams.Subscriber<? super Notification<T>> s) Constructor parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type NotificationModifierConstructorDescription(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
Fields in io.reactivex.rxjava3.internal.operators.maybe with type parameters of type NotificationModifier and TypeFieldDescription(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 NotificationModifier and TypeMethodDescriptionprotected void
MaybeMaterialize.subscribeActual
(SingleObserver<? super Notification<T>> observer) Constructor parameters in io.reactivex.rxjava3.internal.operators.maybe with type arguments of type NotificationModifierConstructorDescription(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 NotificationModifier and TypeFieldDescription(package private) final SingleObserver
<? super Notification<T>> MaterializeSingleObserver.downstream
Constructor parameters in io.reactivex.rxjava3.internal.operators.mixed with type arguments of type NotificationModifierConstructorDescriptionMaterializeSingleObserver
(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 NotificationModifier and TypeFieldDescription(package private) Notification
<T> BlockingObservableLatest.BlockingObservableLatestIterator.iteratorNotification
Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type NotificationModifier and TypeFieldDescriptionprivate 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 NotificationMethods in io.reactivex.rxjava3.internal.operators.observable with parameters of type NotificationModifier and TypeMethodDescriptionvoid
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 NotificationModifier and TypeMethodDescriptionvoid
ObservableMaterialize.subscribeActual
(Observer<? super Notification<T>> t) Constructor parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type NotificationModifierConstructorDescription(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
Fields in io.reactivex.rxjava3.internal.operators.single with type parameters of type NotificationModifier and TypeFieldDescription(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 NotificationModifier and TypeMethodDescriptionprotected void
SingleMaterialize.subscribeActual
(SingleObserver<? super Notification<T>> observer) Constructor parameters in io.reactivex.rxjava3.internal.operators.single with type arguments of type NotificationModifierConstructorDescription(package private)
DematerializeObserver
(MaybeObserver<? super R> downstream, Function<? super T, Notification<R>> selector) SingleDematerialize
(Single<T> source, Function<? super T, Notification<R>> selector)