java – 使用livedata压缩4个或更多异步调用

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java – 使用livedata压缩4个或更多异步调用，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1607字，纯文字阅读大概需要3分钟。

内容图文

是否有任何可能的方法使用livingata并行运行多个异步调用？

假设我有4个异步调用.我想等到一切都完成后再使用所有4个调用的结果.

我能想到的一种方法就是这样

public class MakeParallel {
    private final CountDownLatch countDown = new CountDownLatch(4);

    public void firstCall() {
        Transformation.map(makeFirstCall(), input -> {
            if(input.isSuccessful()) {
                countDownLatch.countDown();
                checkResult();
            }
            return input;
        } 
    }

    public void secondCall() {
        Transformation.map(makeSecondCall(), input -> {
            if(input.isSuccessful()) {
                countDownLatch.countDown();
                checkResult();
            }
            return input;
        } 
    }

    void checkResult() {
        if(countDownLatch.getCount == 0) {
            // Result is ready
        } else {
            // Something has error
        }
    }
}

有没有更好的方法来解决这个场景？

解决方法:

因此,诀窍是使用MediatorLiveData并让它观察每个LiveData对象并将更改压缩到某种类型的集合中.

public static LiveData<ArrayList<Object>> zipLiveData(LiveData<Object>... liveItems){
    final ArrayList<Object> zippedObjects = new ArrayList<>();
    final MediatorLiveData<ArrayList<Object>> mediator = new MediatorLiveData<>();
    for(LiveData<Object> item: liveItems){
        mediator.addSource(item, new Observer<Object>() {
            @Override
            public void onChanged(@Nullable Object o) {
                if(!zippedObjects.contains(o)){
                    zippedObjects.add(o);
                }
                mediator.setValue(zippedObjects);
            }
        });
    }
    return mediator;
}

或者在Kotlin：

fun zipLiveData(vararg liveItems: LiveData<*>): LiveData<ArrayList<Any>> {
return MediatorLiveData<ArrayList<Any>>().apply {
    val zippedObjects = ArrayList<Any>()
    liveItems.forEach {
        addSource(it, { item ->
            if (! zippedObjects.contains(item as Any)) {
                zippedObjects.add(item)
            }
            value = zippedObjects
        })
    }
}}

该解决方案没有类型安全性.随意定制您的需求！

内容总结

以上是互联网集市为您收集整理的java – 使用livedata压缩4个或更多异步调用全部内容，希望文章能够帮你解决java – 使用livedata压缩4个或更多异步调用所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

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

内容手机端