org.apache.reef.wake.rx

Interface RxStage<T>

Type Parameters:

T - type

All Superinterfaces:

AutoCloseable, Observer<T>, Stage

All Known Implementing Classes:

AbstractRxStage, RxSyncStage, RxThreadPoolStage

public interface RxStage<T>
extends Observer<T>, Stage

Stage that executes the observer

Method Summary

Methods inherited from interface org.apache.reef.wake.rx.Observer

onCompleted, onError, onNext

Methods inherited from interface java.lang.AutoCloseable

close