org.apache.reef.wake.rx.impl

Class TimeoutSubject<T>

java.lang.Object

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

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor and Description
TimeoutSubject(long timeout, Observer<T> handler)

Method Summary

Methods

Modifier and Type	Method and Description
void	onCompleted() Notifies the observer that the provider has finished sending push-based notifications.
void	onError(Exception error) Notifies the observer that the provider has experienced an error condition.
void	onNext(T value) Provides the observer with new data.

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeoutSubject

public TimeoutSubject(long timeout,
              Observer<T> handler)

Method Detail

onNext

public void onNext(T value)

Description copied from interface: Observer

Provides the observer with new data.

Specified by:

onNext in interface Observer<T>

onError

public void onError(Exception error)

Description copied from interface: Observer

Notifies the observer that the provider has experienced an error condition.

Specified by:

onError in interface Observer<T>

onCompleted

public void onCompleted()

Description copied from interface: Observer

Notifies the observer that the provider has finished sending push-based notifications.

Specified by:

onCompleted in interface Observer<T>