org.apache.reef.wake.impl

Class BlockingSignalEventHandler<T>

java.lang.Object

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

Type Parameters:

T - type of events

All Implemented Interfaces:

EventHandler<T>

public final class BlockingSignalEventHandler<T>
extends Object
implements EventHandler<T>

An EventHandler that blocks until a set number of Events has been received. Once they have been received, the downstream event handler is called with the last event received. The handler resets atomically to start receiving the next batch of events.

onNext is thread safe

See Also:

BlockingEventHandler

Constructor Summary

Constructors

Constructor and Description
BlockingSignalEventHandler(int expectedSize, EventHandler<T> destination)

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockingSignalEventHandler

public BlockingSignalEventHandler(int expectedSize,
                          EventHandler<T> destination)

Method Detail

onNext

public void onNext(T event)

Description copied from interface: EventHandler

Handles an event.

Specified by:

onNext in interface EventHandler<T>

Parameters:

event - an event