Uses of Class
rx.Notification
Packages that use Notification
Package
Description
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
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 NotificationModifier and TypeFieldDescriptionprivate static final Notification
<Void> Notification.ON_COMPLETED
Methods in rx that return NotificationModifier and TypeMethodDescriptionstatic <T> Notification
<T> Notification.createOnCompleted()
Creates and returns aNotification
of varietyKind.OnCompleted
.static <T> Notification
<T> Notification.createOnCompleted
(Class<T> type) Creates and returns aNotification
of varietyKind.OnCompleted
.static <T> Notification
<T> Notification.createOnError
(Throwable e) Creates and returns aNotification
of varietyKind.OnError
, and assigns it an exception.static <T> Notification
<T> Notification.createOnNext
(T t) Creates and returns aNotification
of varietyKind.OnNext
, and assigns it a value.Methods in rx that return types with arguments of type NotificationModifier and TypeMethodDescriptionfinal 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 withinNotification
objects.Method parameters in rx with type arguments of type NotificationModifier and TypeMethodDescriptionfinal 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 NotificationModifier and TypeFieldDescriptionprivate 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 NotificationModifier and TypeFieldDescriptionprivate 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 NotificationModifier and TypeMethodDescriptionprivate Notification
<? extends T> BlockingOperatorToIterator.SubscriberIterator.take()
Notification
<? extends T> BlockingOperatorNext.NextObserver.takeNext()
Methods in rx.internal.operators that return types with arguments of type NotificationModifier and TypeMethodDescriptionObservable
<? 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 NotificationModifier and TypeMethodDescriptionvoid
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 NotificationModifier and TypeMethodDescriptionObservable
<?> 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 NotificationModifierConstructorDescriptionprivate
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 NotificationModifier and TypeFieldDescription(package private) final Action1
<Notification<? super T>> ActionNotificationObserver.onNotification
Methods in rx.internal.util that return types with arguments of type NotificationModifier and TypeMethodDescriptionstatic 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 NotificationModifier and TypeMethodDescriptionInternalObservableUtils.NotificationErrorExtractor.call
(Notification<?> t) Method parameters in rx.internal.util with type arguments of type NotificationModifier and TypeMethodDescriptionObservable
<?> 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 NotificationModifierConstructorDescriptionActionNotificationObserver
(Action1<Notification<? super T>> onNotification) -
Uses of Notification in rx.observers
Fields in rx.observers with type parameters of type NotificationModifier and TypeFieldDescriptionprivate final List
<Notification<T>> TestObserver.onCompletedEvents
Deprecated.Methods in rx.observers that return types with arguments of type NotificationModifier and TypeMethodDescriptionTestObserver.getOnCompletedEvents()
Deprecated.Get theNotification
s representing each time this observer was notified of sequence completion viaTestObserver.onCompleted()
, as aList
.TestSubscriber.getOnCompletedEvents()
Deprecated.
TestSubscriber.getCompletions()
instead.