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

A Subject that relays all messages to its subscribers. More...

Inherits Org.Apache.REEF.Wake.RX.ISubject< T, T >.

Public Member Functions
	SimpleSubject (IObserver< T > observer)
	Constructs a simple subject More...
virtual void	OnNext (T value)
	Provides the observer with the new value More...
virtual void	OnError (Exception error)
	Provides the observer with the error More...
virtual void	OnCompleted ()
	Provides the observer with it has finished sending push-based notifications. More...

Detailed Description

A Subject that relays all messages to its subscribers.

Constructor & Destructor Documentation

Org.Apache.REEF.Wake.RX.Impl.SimpleSubject< T >.SimpleSubject ( IObserver< T >  observer )

inline

Constructs a simple subject

Parameters

observer

the observer

Member Function Documentation

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

inlinevirtual

Provides the observer with it has finished sending push-based notifications.

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

inlinevirtual

Provides the observer with the error

Parameters

error

the error

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

inlinevirtual

Provides the observer with the new value

Parameters

value

the new value

---

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

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