org.apache.reef.wake.impl

Class BlockingEventHandler<T>

java.lang.Object

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

Type Parameters:

T - type of events

All Implemented Interfaces:

EventHandler<T>

public final class BlockingEventHandler<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 an Iterable of the events spooled.

onNext is thread safe

See Also:

BlockingSignalEventHandler

Constructor Summary

Constructors

Constructor and Description
BlockingEventHandler(int expectedSize, EventHandler<Iterable<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

BlockingEventHandler

public BlockingEventHandler(int expectedSize,
                    EventHandler<Iterable<T>> destination)

Method Detail

onNext

public final void onNext(T event)

Description copied from interface: EventHandler

Handles an event

Specified by:

onNext in interface EventHandler<T>

Parameters:

event - an event