org.apache.reef.wake.rx

Interface Subject<InType,OutType>

Type Parameters:

InType - type for in

OutType - type for out

All Superinterfaces:

Observable, Observer<InType>, StaticObservable

All Known Implementing Classes:

SimpleSubject, TimeoutSubject

public interface Subject<InType,OutType>
extends Observer<InType>, StaticObservable

A class implementing Observer<InType> and StaticObservable<OutType>.

Method Summary

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

onCompleted, onError, onNext