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, isClosed, toString

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, 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:

name - the stage name

handler - the event handler

SyncStage

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

Constructs a synchronous stage.

Parameters:

name - the stage name

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