Org.Apache.REEF.Wake.Examples.P2p.Pull2Push< T > Class Template Reference

Performs a Pull-to-Push conversion in Wake. More...

Inherits Org.Apache.REEF.Wake.Util.IStartable, and IDisposable.

Public Member Functions
	Pull2Push (IEventHandler< T > output)
	Constructs a new Pull2Push object More...
void	Register (IEventSource< T > source)
	Registers an event source. More...
void	Start ()
	Executes the message loop. More...
void	Dispose ()

Detailed Description

Performs a Pull-to-Push conversion in Wake.

Performs a Pull-to-Push conversion in Wake. The class pulls from a set of event sources, and pushes to a single EventHandler. If the downstream event handler blocks, this will block, providing a simple rate limiting scheme. The EventSources are managed in a basic Queue.

Constructor & Destructor Documentation

Org.Apache.REEF.Wake.Examples.P2p.Pull2Push< T >.Pull2Push ( IEventHandler< T >  output )

inline

Constructs a new Pull2Push object

Parameters

output

the EventHandler that receives the messages from this Pull2Push.

Member Function Documentation

void Org.Apache.REEF.Wake.Examples.P2p.Pull2Push< T >.Dispose ( )

inline

void Org.Apache.REEF.Wake.Examples.P2p.Pull2Push< T >.Register ( IEventSource< T >  source )

inline

Registers an event source.

Parameters

source

The source that will be added to the queue of this Pull2Push

void Org.Apache.REEF.Wake.Examples.P2p.Pull2Push< T >.Start ( )

inline

Executes the message loop.

Implements Org.Apache.REEF.Wake.Util.IStartable.

---

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

• lang/cs/Org.Apache.REEF.Wake/Examples/P2p/Pull2Push.cs