微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

android-使用rxjava2遍历列表

我有一个自定义对象列表(List< Item> itemsList).这是我的自定义课程:

public class Item {
    private String itemId;
    private String itemName;
}

初始列表只有itemName; itemId将为空.我想遍历列表,为每个项目添加一个itemId,然后使用新列表,我需要对列表中的每个项目进行某种长时间的操作.

for(Item item : itemsList){
item.setitemId = getUniqueId(); //getUniqueId() returns an unique id
doSomeLongOperation(item);
}

我是rxjava运算符的新手.请帮助我解决如何使用rxjava2实现相同的功能.

谢谢!

解决方法:

使用Observable.fromIterable可以迭代“列表”中的所有项目,并在后台线程上进行订阅以进行后台工作,然后使用Map运算符更新您的项目并进行长时间的工作.完成后返回您需要的东西.

样例代码

        Observable.fromIterable(itemList)
            .subscribeOn(Schedulers.io())
            .map(new Function<Item, Item>() {
                @Override
                public Item apply(Item item) throws Exception {
                     item.setItemId("Id: " +  System.currentTimeMillis());
                      Log.i(TAG, "In Map Item: " + item.toString());
                      // do some long operation and return 

                     return item;
                }
            })
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Consumer<Item>() {
                @Override
                public void accept(Item item) throws Exception {
                    Log.i(TAG, "Item: " + item.toString());
                }
            });

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐