org.apache.reef.wake.rx

Interface Subject<InType,OutType>

Type Parameters:

InType -

OutType -

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

Method Summary

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

onCompleted, onError, onNext