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> A pair having two independent typed items.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
EventHandler<L>	getLeft()
EventHandler<R>	getRight()

Methods inherited from class java.lang.Object

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

Constructor Detail

MergingEventHandler

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

Method Detail

getLeft

public EventHandler<L> getLeft()

getRight

public EventHandler<R> getRight()