org.apache.reef.wake.rx.impl

Class SimpleSubject<T>

java.lang.Object

org.apache.reef.wake.rx.impl.SimpleSubject<T>

Type Parameters:

T -

All Implemented Interfaces:

Observable, Observer<T>, StaticObservable, Subject<T,T>

public class SimpleSubject<T>
extends Object
implements Subject<T,T>

A Subject that relays all messages to its subscribers.

Constructor Summary

Constructors

Constructor and Description
SimpleSubject(Observer<T> observer) Constructs a simple subject.

Method Summary

Methods

Modifier and Type	Method and Description
void	onCompleted() Provides the observer with it has finished sending push-based notifications.
void	onError(Exception error) Provides the observer with the error.
void	onNext(T value) Provides the observer with the new value.

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleSubject

@Inject
public SimpleSubject(Observer<T> observer)

Constructs a simple subject.

Parameters:

observer - the observer

Method Detail

onNext

public void onNext(T value)

Provides the observer with the new value.

Specified by:

onNext in interface Observer<T>

Parameters:

value - the new value

onError

public void onError(Exception error)

Provides the observer with the error.

Specified by:

onError in interface Observer<T>

Parameters:

error - the error

onCompleted

public void onCompleted()

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

Specified by:

onCompleted in interface Observer<T>