org.apache.reef.wake.impl

Class SyncStage<T>

java.lang.Object

org.apache.reef.wake.AbstractEStage<T>

org.apache.reef.wake.impl.SyncStage<T>

Type Parameters:

T - type

All Implemented Interfaces:

AutoCloseable, EStage<T>, EventHandler<T>, Stage

public final class SyncStage<T>
extends AbstractEStage<T>

Stage that synchronously executes an event handler

Constructor Summary

Constructors

Constructor and Description
SyncStage(EventHandler<T> handler) Constructs a synchronous stage
SyncStage(String name, EventHandler<T> handler) Constructs a synchronous stage
SyncStage(String name, EventHandler<T> handler, EventHandler<Throwable> errorHandler) Constructs a synchronous stage

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes resources
void	onNext(T value) Invokes the handler for the event

Methods inherited from class org.apache.reef.wake.AbstractEStage

getInMeter, getOutMeter

Methods inherited from class java.lang.Object

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

Constructor Detail

SyncStage

@Inject
public SyncStage(EventHandler<T> handler)

Constructs a synchronous stage

Parameters:

handler - the event handler

SyncStage

@Inject
public SyncStage(String name,
                EventHandler<T> handler)

Constructs a synchronous stage

Parameters:

handler - the event handler

SyncStage

@Inject
public SyncStage(String name,
                EventHandler<T> handler,
                EventHandler<Throwable> errorHandler)

Constructs a synchronous stage

Parameters:

handler - the event handler

errorHandler - the error handler

Method Detail

onNext

public void onNext(T value)

Invokes the handler for the event

Parameters:

value - the event

close

public void close()
           throws Exception

Closes resources

Throws:

Exception