RxJava

rx

Interface Observable.OnSubscribeFunc<T>