Observable.create(new ObservableOnSubscribe<Object>() {
    @Override
    public void subscribe(ObservableEmitter<Object> emitter) throws Exception {
        if(mHistoryDao != null) {
            mHistoryDao.listHistories();
        }
    }
}).subscribeOn(Schedulers.io()).subscribe();

为什么presenter对Dao操作时要用到rxjava，第一次见这样用。目的是什么呢？