Uses of Class
rx.Notification

Packages that use Notification

Package	Description
rx	Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.
rx.internal.operators	Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
rx.internal.util
rx.observers	Default wrappers and implementations for the base reactive consumer classes and interfaces; utility classes for creating them from callbacks.

Uses of Notification in rx

Fields in rx declared as Notification

Modifier and Type	Field	Description
private static final Notification<Void>	Notification.ON_COMPLETED

Methods in rx that return Notification

Modifier and Type	Method	Description
static <T> Notification<T>	Notification.createOnCompleted()	Creates and returns a Notification of variety Kind.OnCompleted.
static <T> Notification<T>	Notification.createOnCompleted(Class<T> type)	Creates and returns a Notification of variety Kind.OnCompleted.
static <T> Notification<T>	Notification.createOnError(Throwable e)	Creates and returns a Notification of variety Kind.OnError, and assigns it an exception.
static <T> Notification<T>	Notification.createOnNext(T t)	Creates and returns a Notification of variety Kind.OnNext, and assigns it a value.

Methods in rx that return types with arguments of type Notification

Modifier and Type	Method	Description
final Observable<Notification<T>>	Observable.materialize()	Returns an Observable that represents all of the emissions and notifications from the source Observable into emissions marked with their original types within Notification objects.

Method parameters in rx with type arguments of type Notification

Modifier and Type	Method	Description
final Observable<T>	Observable.doOnEach(Action1<Notification<? super T>> onNotification)	Modifies the source Observable so that it invokes an action for each item it emits.

Uses of Notification in rx.internal.operators

Fields in rx.internal.operators declared as Notification

Modifier and Type	Field	Description
private Notification<? extends T>	BlockingOperatorToIterator.SubscriberIterator.buf
(package private) Notification<? extends T>	BlockingOperatorLatest.LatestObserverIterator.iNotif
private Notification<T>	OperatorMaterialize.ParentSubscriber.terminalNotification

Fields in rx.internal.operators with type parameters of type Notification

Modifier and Type	Field	Description
private final BlockingQueue<Notification<? extends T>>	BlockingOperatorNext.NextObserver.buf
private final Subscriber<? super Notification<T>>	OperatorMaterialize.ParentSubscriber.child
private final Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>>	OnSubscribeRedo.controlHandlerFunction
private final BlockingQueue<Notification<? extends T>>	BlockingOperatorToIterator.SubscriberIterator.notifications
(package private) static final Func1<Observable<? extends Notification<?>>,Observable<?>>	OnSubscribeRedo.REDO_INFINITE
(package private) final AtomicReference<Notification<? extends T>>	BlockingOperatorLatest.LatestObserverIterator.value

Methods in rx.internal.operators that return Notification

Modifier and Type	Method	Description
private Notification<? extends T>	BlockingOperatorToIterator.SubscriberIterator.take()
Notification<? extends T>	BlockingOperatorNext.NextObserver.takeNext()

Methods in rx.internal.operators that return types with arguments of type Notification

Modifier and Type	Method	Description
Observable<? extends Notification<?>>	OnSubscribeRedo.RetryWithPredicate.call(Observable<? extends Notification<?>> ts)
Subscriber<? super Notification<T>>	OperatorDematerialize.call(Subscriber<? super T> child)

Methods in rx.internal.operators with parameters of type Notification

Modifier and Type	Method	Description
void	BlockingOperatorLatest.LatestObserverIterator.onNext(Notification<? extends T> args)
void	BlockingOperatorNext.NextObserver.onNext(Notification<? extends T> args)
void	BlockingOperatorToIterator.SubscriberIterator.onNext(Notification<? extends T> args)

Method parameters in rx.internal.operators with type arguments of type Notification

Modifier and Type	Method	Description
Observable<?>	OnSubscribeRedo.RedoFinite.call(Observable<? extends Notification<?>> ts)
Observable<? extends Notification<?>>	OnSubscribeRedo.RetryWithPredicate.call(Observable<? extends Notification<?>> ts)
Subscriber<? super T>	OperatorMaterialize.call(Subscriber<? super Notification<T>> child)
static <T> Observable<T>	OnSubscribeRedo.redo(Observable<T> source, Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler, Scheduler scheduler)
static <T> Observable<T>	OnSubscribeRedo.repeat(Observable<T> source, Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler)
static <T> Observable<T>	OnSubscribeRedo.repeat(Observable<T> source, Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler, Scheduler scheduler)
static <T> Observable<T>	OnSubscribeRedo.retry(Observable<T> source, Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler)
static <T> Observable<T>	OnSubscribeRedo.retry(Observable<T> source, Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler, Scheduler scheduler)

Constructor parameters in rx.internal.operators with type arguments of type Notification

Modifier	Constructor	Description
private	OnSubscribeRedo(Observable<T> source, Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> f, boolean stopOnComplete, boolean stopOnError, Scheduler scheduler)
(package private)	ParentSubscriber(Subscriber<? super Notification<T>> child)

Uses of Notification in rx.internal.util

Fields in rx.internal.util with type parameters of type Notification

Modifier and Type	Field	Description
(package private) final Action1<Notification<? super T>>	ActionNotificationObserver.onNotification

Methods in rx.internal.util that return types with arguments of type Notification

Modifier and Type	Method	Description
static final Func1<Observable<? extends Notification<?>>,Observable<?>>	InternalObservableUtils.createRepeatDematerializer(Func1<? super Observable<? extends Void>,? extends Observable<?>> notificationHandler)	Returns a function that dematerializes the notification signal from an Observable and calls a notification handler with a null for non-terminal events.
static final Func1<Observable<? extends Notification<?>>,Observable<?>>	InternalObservableUtils.createRetryDematerializer(Func1<? super Observable<? extends Throwable>,? extends Observable<?>> notificationHandler)	Returns a function that dematerializes the notification signal from an Observable and calls a notification handler with the Throwable.

Methods in rx.internal.util with parameters of type Notification

Modifier and Type	Method	Description
Throwable	InternalObservableUtils.NotificationErrorExtractor.call(Notification<?> t)

Method parameters in rx.internal.util with type arguments of type Notification

Modifier and Type	Method	Description
Observable<?>	InternalObservableUtils.RepeatNotificationDematerializer.call(Observable<? extends Notification<?>> notifications)
Observable<?>	InternalObservableUtils.RetryNotificationDematerializer.call(Observable<? extends Notification<?>> notifications)

Constructor parameters in rx.internal.util with type arguments of type Notification

Modifier	Constructor	Description
	ActionNotificationObserver(Action1<Notification<? super T>> onNotification)

Uses of Notification in rx.observers

Fields in rx.observers with type parameters of type Notification

Modifier and Type	Field	Description
private final List<Notification<T>>	TestObserver.onCompletedEvents	Deprecated.

Methods in rx.observers that return types with arguments of type Notification

Modifier and Type	Method	Description
List<Notification<T>>	TestObserver.getOnCompletedEvents()	Deprecated. Get the Notifications representing each time this observer was notified of sequence completion via TestObserver.onCompleted(), as a List.
List<Notification<T>>	TestSubscriber.getOnCompletedEvents()	Deprecated. use TestSubscriber.getCompletions() instead.