RxJava

rx.subjects

Class AsyncSubject<T>