Package rx.internal.util

Class ActionNotificationObserver<T>

java.lang.Object

rx.internal.util.ActionNotificationObserver<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

Observer<T>

public final class ActionNotificationObserver<T>
extends Object
implements Observer<T>

An Observer that forwards the onXXX method calls to a notification callback by transforming each signal type into Notifications.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Action1<Notification<? super T>>	onNotification

Constructor Summary

Constructors

Constructor	Description
ActionNotificationObserver(Action1<Notification<? super T>> onNotification)

Method Summary

Modifier and Type	Method	Description
void	onCompleted()	Notifies the Observer that the Observable has finished sending push-based notifications.
void	onError(Throwable e)	Notifies the Observer that the Observable has experienced an error condition.
void	onNext(T t)	Provides the Observer with a new item to observe.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

onNotification

final Action1<Notification<? super T>> onNotification

Constructor Details

ActionNotificationObserver

public ActionNotificationObserver(Action1<Notification<? super T>> onNotification)

Method Details

onNext

public void onNext(T t)

Description copied from interface: Observer

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either Observer.onCompleted() or Observer.onError(java.lang.Throwable).

Specified by:

onNext in interface Observer<T>

Parameters:

t - the item emitted by the Observable

onError

public void onError(Throwable e)

Description copied from interface: Observer

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call Observer.onNext(T) or Observer.onCompleted().

Specified by:

onError in interface Observer<T>

Parameters:

e - the exception encountered by the Observable

onCompleted

public void onCompleted()

Description copied from interface: Observer

Notifies the Observer that the Observable has finished sending push-based notifications.

The Observable will not call this method if it calls Observer.onError(java.lang.Throwable).

Specified by:

onCompleted in interface Observer<T>