Packages that use Notification

• Uses of Notification in rx

  Methods in that return

  Modifier and Type	Method and 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 that return types with arguments of type

  Modifier and Type	Method and 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 within Notification objects.

  Method parameters in rx with type arguments of type Notification

  Modifier and Type	Method and 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

  Methods in that return types with arguments of type

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

  Methods in with parameters of type

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

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

  Modifier and Type	Method and 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)

• Uses of Notification in rx.observers

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

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