org.apache.reef.wake.examples.join

Class EventPrinter<T>

java.lang.Object

org.apache.reef.wake.examples.join.EventPrinter<T>

Type Parameters:

T - the type of the event

All Implemented Interfaces:

Observer<T>

public class EventPrinter<T>
extends Object
implements Observer<T>

Event printer.

Constructor Summary

Constructors

Constructor and Description
EventPrinter()

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.
void	onNext(T value) Provides the observer with new data.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventPrinter

public EventPrinter()

Method Detail

onNext

public void onNext(T value)

Description copied from interface: Observer

Provides the observer with new data.

Specified by:

onNext in interface Observer<T>

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>