Uses of Interface
org.apache.reef.wake.rx.Observer

Packages that use Observer

Package	Description
org.apache.reef.wake.examples.accumulate
org.apache.reef.wake.examples.join
org.apache.reef.wake.rx
org.apache.reef.wake.rx.impl

Uses of Observer in org.apache.reef.wake.examples.accumulate

Methods in org.apache.reef.wake.examples.accumulate that return Observer

Modifier and Type	Method and Description
Observer<Map.Entry<K,V>>	CombinerStage.wireIn()

Constructors in org.apache.reef.wake.examples.accumulate with parameters of type Observer

Constructor and Description
CombinerStage(CombinerStage.Combiner<K,V> c, Observer<Map.Entry<K,V>> o)

Uses of Observer in org.apache.reef.wake.examples.join

Classes in org.apache.reef.wake.examples.join that implement Observer

Modifier and Type	Class and Description
class	EventPrinter<T>

Methods in org.apache.reef.wake.examples.join that return Observer

Modifier and Type	Method and Description
Observer<TupleEvent>	NonBlockingJoin.wireLeft()
Observer<TupleEvent>	BlockingJoin.wireLeft()
Observer<TupleEvent>	NonBlockingJoin.wireRight()
Observer<TupleEvent>	BlockingJoin.wireRight()

Constructors in org.apache.reef.wake.examples.join with parameters of type Observer

Constructor and Description
BlockingJoin(Observer<TupleEvent> out)
NonBlockingJoin(Observer<TupleEvent> out)
TupleSource(Observer<TupleEvent> out, int max, int numThreads, boolean evenOnly)

Uses of Observer in org.apache.reef.wake.rx

Subinterfaces of Observer in org.apache.reef.wake.rx

Modifier and Type	Interface and Description
interface	RxStage<T> Stage that executes the observer
interface	Subject<InType,OutType> A class implementing Observer and StaticObservable.

Classes in org.apache.reef.wake.rx that implement Observer

Modifier and Type	Class and Description
class	AbstractObserver<T> An Observer with logging-only onError and onCompleted() methods.
class	AbstractRxStage<T> An RxStage that implements metering

Methods in org.apache.reef.wake.rx with parameters of type Observer

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

Uses of Observer in org.apache.reef.wake.rx.impl

Classes in org.apache.reef.wake.rx.impl that implement Observer

Modifier and Type	Class and Description
class	RxSyncStage<T> Stage that executes the observer synchronously
class	RxThreadPoolStage<T> Stage that executes the observer with a thread pool.
class	SimpleSubject<T> A Subject that relays all messages to its subscribers.
class	TimeoutSubject<T>

Constructors in org.apache.reef.wake.rx.impl with parameters of type Observer

Constructor and Description
RxSyncStage(Observer<T> observer) Constructs a Rx synchronous stage
RxSyncStage(String name, Observer<T> observer) Constructs a Rx synchronous stage
RxThreadPoolStage(Observer<T> observer, int numThreads) Constructs a Rx thread pool stage
RxThreadPoolStage(String name, Observer<T> observer, int numThreads) Constructs a Rx thread pool stage
SimpleSubject(Observer<T> observer) Constructs a simple subject
TimeoutSubject(long timeout, Observer<T> handler)