Handler to process an event in a way that has certain probability of failure within certain inverval of time. More...

Inherits IObserver< T >.

Public Member Functions
void	OnNext (T value)
	Throws a PoisonException with probability CrashProbability between time CrashMinDelay and CrashMinDelay + CrashTimeout. More...

void	OnError (Exception error)

void	OnCompleted ()

Detailed Description

Handler to process an event in a way that has certain probability of failure within certain inverval of time.

Template Parameters

T	The type of event

Member Function Documentation

void Org.Apache.REEF.Common.Poison.PoisonedEventHandler< T >.OnCompleted ( )

inline

void Org.Apache.REEF.Common.Poison.PoisonedEventHandler< T >.OnError ( Exception error )

inline

void Org.Apache.REEF.Common.Poison.PoisonedEventHandler< T >.OnNext ( T value )

inline

Uses a separate thread to throw the exception.

The documentation for this class was generated from the following file: