Observable.create(new Observable.OnSubscribe<List<SpeechResourceModel>>() { @Override public void call(Subscriber<? super List<SpeechResourceModel>> subscriber) { subscriber.onNext(); } }).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()) .subscribe(new Action1<List<SpeechResourceModel>>(){ @Override public void call(List<SpeechResourceModel> data) { } });
Gradle配置java
compile "io.reactivex:rxjava:1.1.0" compile "io.reactivex:rxandroid:1.1.0"