Package rx

Class Notification<T>

java.lang.Object
rx.Notification<T>
Type Parameters:
T - the actual value type held by the Notification

public final class Notification<T> extends Object
An object representing a notification sent to an Observable.
  • Field Details

  • Constructor Details

  • Method Details

    • createOnNext

      public static <T> Notification<T> createOnNext(T t)
      Creates and returns a Notification of variety Kind.OnNext, and assigns it a value.
      Type Parameters:
      T - the actual value type held by the Notification
      Parameters:
      t - the item to assign to the notification as its value
      Returns:
      an OnNext variety of Notification
    • createOnError

      public static <T> Notification<T> createOnError(Throwable e)
      Creates and returns a Notification of variety Kind.OnError, and assigns it an exception.
      Type Parameters:
      T - the actual value type held by the Notification
      Parameters:
      e - the exception to assign to the notification
      Returns:
      an OnError variety of Notification
    • createOnCompleted

      public static <T> Notification<T> createOnCompleted()
      Creates and returns a Notification of variety Kind.OnCompleted.
      Type Parameters:
      T - the actual value type held by the Notification
      Returns:
      an OnCompleted variety of Notification
    • createOnCompleted

      public static <T> Notification<T> createOnCompleted(Class<T> type)
      Creates and returns a Notification of variety Kind.OnCompleted.
      Type Parameters:
      T - the actual value type held by the Notification
      Parameters:
      type -
      Returns:
      an OnCompleted variety of Notification
    • getThrowable

      public Throwable getThrowable()
      Retrieves the exception associated with this (onError) notification.
      Returns:
      the Throwable associated with this (onError) notification
    • getValue

      public T getValue()
      Retrieves the item associated with this (onNext) notification.
      Returns:
      the item associated with this (onNext) notification
    • hasValue

      public boolean hasValue()
      Indicates whether this notification has an item associated with it.
      Returns:
      a boolean indicating whether or not this notification has an item associated with it
    • hasThrowable

      public boolean hasThrowable()
      Indicates whether this notification has an exception associated with it.
      Returns:
      a boolean indicating whether this notification has an exception associated with it
    • getKind

      public Notification.Kind getKind()
      Retrieves the kind of this notification: OnNext, OnError, or OnCompleted
      Returns:
      the kind of the notification: OnNext, OnError, or OnCompleted
    • isOnError

      public boolean isOnError()
      Indicates whether this notification represents an onError event.
      Returns:
      a boolean indicating whether this notification represents an onError event
    • isOnCompleted

      public boolean isOnCompleted()
      Indicates whether this notification represents an onCompleted event.
      Returns:
      a boolean indicating whether this notification represents an onCompleted event
    • isOnNext

      public boolean isOnNext()
      Indicates whether this notification represents an onNext event.
      Returns:
      a boolean indicating whether this notification represents an onNext event
    • accept

      public void accept(Observer<? super T> observer)
      Forwards this notification on to a specified Observer.
      Parameters:
      observer - the target observer to call onXXX methods on based on the kind of this Notification instance
    • toString

      public String toString()
      Overrides:
      toString in class Object
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object
    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class Object