org.apache.reef.wake.rx

Interface Observer<T>

Type Parameters:

T -

All Known Subinterfaces:

RxStage<T>, Subject<InType,OutType>

All Known Implementing Classes:

AbstractObserver, AbstractRxStage, EventPrinter, RxSyncStage, RxThreadPoolStage, SimpleSubject, TimeoutSubject

public interface Observer<T>

Provides a mechanism for receiving push-based notifications. Implicit contract: zero or more calls of onNext, if a sequence terminates, it is terminated by onError or onCompleted in T

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.

Method Detail

onNext

void onNext(T value)

Provides the observer with new data.

Parameters:

value -

onError

void onError(Exception error)

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

Parameters:

error -

onCompleted

void onCompleted()

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