org.apache.reef.examples.utils.wake

Class LoggingEventHandler<T>

java.lang.Object

org.apache.reef.examples.utils.wake.LoggingEventHandler<T>

Type Parameters:

T -

All Implemented Interfaces:

EventHandler<T>

public class LoggingEventHandler<T>
extends Object
implements EventHandler<T>

An EventHandler that logs its events before handing it to a downstream EventHandler.

Constructor Summary

Constructors

Constructor and Description
LoggingEventHandler(EventHandler<T> downstreamEventHandler)
LoggingEventHandler(String prefix, EventHandler<T> downstreamEventHandler, String suffix)

Method Summary

Methods

Modifier and Type	Method and Description
void	onNext(T value) Handles an event

Methods inherited from class java.lang.Object

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

Constructor Detail

LoggingEventHandler

public LoggingEventHandler(String prefix,
                   EventHandler<T> downstreamEventHandler,
                   String suffix)

Parameters:

prefix - to be logged before the event

downstreamEventHandler - the event handler to hand the event to

suffix - to be logged after the event

LoggingEventHandler

public LoggingEventHandler(EventHandler<T> downstreamEventHandler)

Method Detail

onNext

public void onNext(T value)

Description copied from interface: EventHandler

Handles an event

Specified by:

onNext in interface EventHandler<T>

Parameters:

value - an event