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 Notification<java.lang.Void>
Notification. ON_COMPLETED
Methods in rx that return Notification Modifier and Type Method Description static <T> Notification<T>
Notification. createOnCompleted()
Creates and returns aNotification
of varietyKind.OnCompleted
.static <T> Notification<T>
Notification. createOnCompleted(java.lang.Class<T> type)
Creates and returns aNotification
of varietyKind.OnCompleted
.static <T> Notification<T>
Notification. createOnError(java.lang.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 Notification Modifier and Type Method Description 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 Notification Modifier and Type Method Description 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 java.util.concurrent.BlockingQueue<Notification<? extends T>>
BlockingOperatorNext.NextObserver. buf
private Subscriber<? super Notification<T>>
OperatorMaterialize.ParentSubscriber. child
private Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>>
OnSubscribeRedo. controlHandlerFunction
private java.util.concurrent.BlockingQueue<Notification<? extends T>>
BlockingOperatorToIterator.SubscriberIterator. notifications
(package private) static Func1<Observable<? extends Notification<?>>,Observable<?>>
OnSubscribeRedo. REDO_INFINITE
(package private) java.util.concurrent.atomic.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 Constructor Description OnSubscribeRedo(Observable<T> source, Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> f, boolean stopOnComplete, boolean stopOnError, Scheduler scheduler)
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) 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 Func1<Observable<? extends Notification<?>>,Observable<?>>
InternalObservableUtils. createRepeatDematerializer(Func1<? super Observable<? extends java.lang.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 Func1<Observable<? extends Notification<?>>,Observable<?>>
InternalObservableUtils. createRetryDematerializer(Func1<? super Observable<? extends java.lang.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 java.lang.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 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 java.util.List<Notification<T>>
TestObserver. onCompletedEvents
Deprecated.Methods in rx.observers that return types with arguments of type Notification Modifier and Type Method Description java.util.List<Notification<T>>
TestObserver. getOnCompletedEvents()
Deprecated.Get theNotification
s representing each time this observer was notified of sequence completion viaTestObserver.onCompleted()
, as aList
.java.util.List<Notification<T>>
TestSubscriber. getOnCompletedEvents()
Deprecated.useTestSubscriber.getCompletions()
instead.
-