org.apache.reef.wake.impl

Class MergingEventHandler<L,R>

java.lang.Object

org.apache.reef.wake.impl.MergingEventHandler<L,R>

Type Parameters:

L - type of event

R - type of event

public final class MergingEventHandler<L,R>
extends Object

An EventHandler combines two events of different types into a single Pair of events. Handler will block until both events are received.

onNext is thread safe

See Also:

BlockingEventHandler

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MergingEventHandler.Pair<S1,S2>

Field Summary

Fields

Modifier and Type	Field and Description
EventHandler<L>	left
EventHandler<R>	right

Constructor Summary

Constructors

Constructor and Description
MergingEventHandler(EventHandler<MergingEventHandler.Pair<L,R>> destination)

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

left

public final EventHandler<L> left

right

public final EventHandler<R> right

Constructor Detail

MergingEventHandler

@Inject
public MergingEventHandler(EventHandler<MergingEventHandler.Pair<L,R>> destination)