Org.Apache.REEF.Wake.RX.Impl.PubSubSubject< T > Class Template Reference

Subject to provide publish/subscribe interface. More...

Inherits IObserver< T >.

Public Member Functions
	PubSubSubject ()
	Constructs a pub-sub Subject More...
void	OnCompleted ()
	Log on completion More...
void	OnError (Exception error)
	Log Exception More...
void	OnNext (T value)
	Invoke the subscribed handlers for the event class type More...
IDisposable	Subscribe< U > (IObserver< U > observer)
	Subscribe an IObserver for an event type More...

Detailed Description

Subject to provide publish/subscribe interface.

Subscribes to class Types and invokes handlers for a given type on call to OnNext

Template Parameters

T	The super type that all event types inherit from

Constructor & Destructor Documentation

Org.Apache.REEF.Wake.RX.Impl.PubSubSubject< T >.PubSubSubject ( )

inline

Constructs a pub-sub Subject

Member Function Documentation

void Org.Apache.REEF.Wake.RX.Impl.PubSubSubject< T >.OnCompleted ( )

inline

Log on completion

void Org.Apache.REEF.Wake.RX.Impl.PubSubSubject< T >.OnError ( Exception  error )

inline

Log Exception

Parameters

error

void Org.Apache.REEF.Wake.RX.Impl.PubSubSubject< T >.OnNext ( T  value )

inline

Invoke the subscribed handlers for the event class type

Parameters

value

The event to process

IDisposable Org.Apache.REEF.Wake.RX.Impl.PubSubSubject< T >.Subscribe< U > ( IObserver< U >  observer )

inline

Subscribe an IObserver for an event type

Template Parameters

U	The event type

Parameters

observer

The observer to handle the event

Returns

An IDisposable object used to handle unsubscribing the IObserver

Type Constraints

U

:

T

---

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

• lang/cs/Org.Apache.REEF.Wake/RX/Impl/PubSubSubject.cs