从 RxAndroid 替换异步任务答案

【问题标题】：Replace Async Task from RxAndroid从 RxAndroid 替换异步任务
【发布时间】：2017-07-14 12:27:25
【问题描述】：

我是 rxAndroid 的新手，我只是简单地从 rxAndroid 替换 asynTask。我只想在后台使用 db 查询创建一个列表

new AsyncTask<Void, Void, Void>() {
        @Override
        protected void onPreExecute() {
            super.onPreExecute();
            startSppiner();
        }

        @Override
        protected Void doInBackground(Void... params) {
        List<masterDataTable> list = ServatiumApplication.daoSession.getMasterDataTableDao().queryBuilder().where(masterDataTableDao.Properties.MasterType.eq(ParserString.MD_SERVICE_LEVEL), masterDataTableDao.Properties.DeleteFlag.eq(SHOW_FLAG)).orderAsc(masterDataTableDao.Properties.Description).list();
        if (list.size() > 0) {
        PopUpValues values1 = new PopUpValues();
        values1.setValue(ParserString.SELECT_VALUE);
        values1.setName(ParserString.SELECT);
        serviceLevelList.add(values1);

        for (masterDataTable item : list) {
            PopUpValues values = new PopUpValues();
            values.setValue(item.getLookupCode());
            values.setName(item.getDescription());
            serviceLevelList.add(values);
        }

    }
            return null;
        }

        @Override
        protected void onPostExecute(Void aVoid) {
            stopSppiner();

        }
    }.execute();

提前感谢您的帮助！

【问题讨论】：

stackoverflow.com/questions/31592399/…
我只是想扩充一个列表，你不能分享一些与它相关的代码

标签： android database android-asynctask rx-java rx-android

【解决方案1】：

这样就可以了。

public void query(){
    startSppiner();
    Observable.fromCallable(new Func0<List<PopUpValues>>() {
        @Override
        public List<PopUpValues> call() {
            List<masterDataTable> list = ServatiumApplication.daoSession.getMasterDataTableDao().queryBuilder().where(masterDataTableDao.Properties.MasterType.eq(ParserString.MD_SERVICE_LEVEL), masterDataTableDao.Properties.DeleteFlag.eq(SHOW_FLAG)).orderAsc(masterDataTableDao.Properties.Description).list();
            List<PopUpValues> serviceLevelList = new ArrayList<PopUpValues>();
            if (list.size() > 0) {
                PopUpValues values1 = new PopUpValues();
                values1.setValue(ParserString.SELECT_VALUE);
                values1.setName(ParserString.SELECT);
                serviceLevelList.add(values1);

                for (masterDataTable item : list) {
                    PopUpValues values = new PopUpValues();
                    values.setValue(item.getLookupCode());
                    values.setName(item.getDescription());
                    serviceLevelList.add(values);
                }

            }
            return serviceLevelList;
        }
    })
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new Subscriber<List<PopUpValues>>() {
        @Override
        public void onCompleted() {
            stopSppiner();
        }

        @Override
        public void onError(Throwable e) {

        }

        @Override
        public void onNext(List<PopUpValues> popUpValues) {
            // Here you get the serviceLevelList data
        }
    });
}

【讨论】：

感谢您的回答，我们可以使用相同的 Observable 从 DB 中获取多个列表吗？如果是，那么如何。
视情况而定，多个列表的模型是什么，如果相同则可以，都可以合并为一个。
我们如何返回多个列表
从基本的 rxjava 教程和操作符开始。

【解决方案2】：

下面是我尝试使用上面提供的 AsyncTask 代码转换为 Rx 的代码。您可能需要稍作修改，但总体流程保持不变。

Observable
    .fromIterable(
        ServatiumApplication.daoSession
            .getMasterDataTableDao()
            .queryBuilder()
            .where(
               masterDataTableDao
                  .Properties
                  .MasterType
                  .eq(ParserString.MD_SERVICE_LEVEL),
               masterDataTableDao.Properties.DeleteFlag.eq(SHOW_FLAG)
            )
            .orderAsc(masterDataTableDao.Properties.Description)
            .list()
    )
    //Get item one by one from the above list, create a PopupValues object and add to it
    .map(
        listItem -> {
            PopUpValues values = new PopUpValues();
            values.setValue(listItem.getLookupCode());
            values.setName(listItem.getDescription());
            return values;
        }
    )
    //Convert to List<PopupValues> list. toList() returns Single<List<PopupValues>>
    .toList()
    //When subscribe is called show spinner
    .doOnSubscribe(disposable -> startSppiner())
    //When job is done successfully or fails stop spinner
    .doOnSuccess(listOfPopupValues -> stopSppiner())
    .doOnError(throwable -> stopSpinner())
    //Do the job in io() thread
    .subscribeOn(Schedulers.io())
    //Give the resulting list to mainthread
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(
        result -> "get the List<PopUpValues>",
        error -> new Throwable("")
    );

【讨论】：