org.apache.reef.wake.rx

Interface StaticObservable

All Superinterfaces:

Observable

All Known Subinterfaces:

Subject<InType,OutType>

All Known Implementing Classes:

BlockingJoin, NonBlockingJoin, SimpleSubject, TupleSource

public interface StaticObservable
extends Observable

Defines a "static" provider for push-based notification. Observers are statically configured in constructing a static observable object.