org.apache.reef.wake.rx

Class AbstractObserver<T>

java.lang.Object

org.apache.reef.wake.rx.AbstractObserver<T>

Type Parameters:

T - type

All Implemented Interfaces:

Observer<T>

public abstract class AbstractObserver<T>
extends Object
implements Observer<T>

An Observer with logging-only onError and onCompleted() methods.

Constructor Summary

Constructors

Constructor and Description
AbstractObserver()

Method Summary

Methods

Modifier and Type	Method and Description
void	onCompleted() Notifies the observer that the provider has finished sending push-based notifications.
void	onError(Exception error) Notifies the observer that the provider has experienced an error condition.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.reef.wake.rx.Observer

onNext

Constructor Detail

AbstractObserver

public AbstractObserver()

Method Detail

onError

public void onError(Exception error)

Description copied from interface: Observer

Notifies the observer that the provider has experienced an error condition.

Specified by:

onError in interface Observer<T>

onCompleted

public void onCompleted()

Description copied from interface: Observer

Notifies the observer that the provider has finished sending push-based notifications.

Specified by:

onCompleted in interface Observer<T>