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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	Notification.Kind	Specifies the kind of the notification: an element, an error or a completion notification.

Field Summary

Fields

Modifier and Type	Field	Description
private final Notification.Kind	kind
private static final Notification<Void>	ON_COMPLETED
private final Throwable	throwable
private final T	value

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Notification(Notification.Kind kind, T value, Throwable e)

Method Summary

Modifier and Type	Method	Description
void	accept(Observer<? super T> observer)	Forwards this notification on to a specified Observer.
static <T> Notification<T>	createOnCompleted()	Creates and returns a Notification of variety Kind.OnCompleted.
static <T> Notification<T>	createOnCompleted(Class<T> type)	Creates and returns a Notification of variety Kind.OnCompleted.
static <T> Notification<T>	createOnError(Throwable e)	Creates and returns a Notification of variety Kind.OnError, and assigns it an exception.
static <T> Notification<T>	createOnNext(T t)	Creates and returns a Notification of variety Kind.OnNext, and assigns it a value.
boolean	equals(Object obj)
Notification.Kind	getKind()	Retrieves the kind of this notification: OnNext, OnError, or OnCompleted
Throwable	getThrowable()	Retrieves the exception associated with this (onError) notification.
T	getValue()	Retrieves the item associated with this (onNext) notification.
int	hashCode()
boolean	hasThrowable()	Indicates whether this notification has an exception associated with it.
boolean	hasValue()	Indicates whether this notification has an item associated with it.
boolean	isOnCompleted()	Indicates whether this notification represents an onCompleted event.
boolean	isOnError()	Indicates whether this notification represents an onError event.
boolean	isOnNext()	Indicates whether this notification represents an onNext event.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

kind

private final Notification.Kind kind

throwable

private final Throwable throwable

value

private final T value

ON_COMPLETED

private static final Notification<Void> ON_COMPLETED

Constructor Details

Notification

private Notification(Notification.Kind kind,
 T value,
 Throwable e)

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