org.apache.reef.wake.rx

Interface Observable

All Known Subinterfaces:

DynamicObservable<T>, StaticObservable, Subject<InType,OutType>

All Known Implementing Classes:

BlockingJoin, NonBlockingJoin, SimpleSubject, TimeoutSubject, TupleSource

public interface Observable

Defines a provider for push-based notification