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

Packages that use Observer

Package	Description
org.apache.reef.wake.examples.accumulate	A key-value combiner example.
org.apache.reef.wake.examples.join	Blocking and non-blocking join example.
org.apache.reef.wake.rx	Wake's RX-style communication.
org.apache.reef.wake.rx.impl	Wake's RX-style communication implementation.

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> Event printer.

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<InType> and StaticObservable<OutType>.

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.

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.