org.apache.reef.wake.rx

Interface DynamicObservable<T>

Type Parameters:

T - type

All Superinterfaces:

Observable

public interface DynamicObservable<T>
extends Observable

Defines a "dynamically configured" provider for push-based notification. Observers can be dynamically subscribed at run time.

Method Summary

Methods

Modifier and Type	Method and Description
AutoCloseable	subscribe(Observer<T> o) Subscribes the observer to this observable object.

Method Detail

subscribe

AutoCloseable subscribe(Observer<T> o)

Subscribes the observer to this observable object.

Parameters:

o - the observer

Returns:

a subscription handle