如何根据多个RxJava可完成结果的结果执行操作

编程问答 2022-08-15

问题描述

已经花了我一段时间了，我在管理必须在Kotlin中使用Rx的需求时迷失了。

让我解释一下。

有一组ID，其等价项需要根据服务器的成功从服务器中删除，并最终在本地删除。

基本上

  1. 进行网络通话以删除单个id（受支持的网络通话返回Completable）
  2. 如果收到complete（成功）回调，则将id存储在list（内存）中
  3. 对所有id进行删除，请执行第一步和第二步
  4. 每个网络呼叫完成后，将列表传递出去，以从本地数据库中删除

因此这些功能可用，无法修改。

  1. fun deleteId(id: String): Completable { networkCall.deleteId(id) }
  2. fun deleteIds(ids: List<String>): Unit { localDb.deleteId(ids) }

这是我尝试过的方法，但显然不完整且被卡住... 

val deleted = CopyOnWriteArrayList<String>()
val error = CopyOnWriteArrayList<String>()
items?.filter { it.isChecked }
    ?.map { Pair(it.id,dataManager.deleteId(it.id)) }
    ?.forEach { (Id,deleteOp) ->
        deleteOp.subscribeOn(Schedulers.io())
                .subscribe(object: CompletableObserver {
                    override fun onComplete() { deleted.add(Id) }

                    override fun onSubscribe(d: Disposable) { disposableManager += d }

                    override fun onError(e: Throwable) { error.add(Id) }

                })
    }

所以现在这里存在多个问题，其中之一是要求我无法找到一个地方来知道所有请求均已完成，从而启动localDb删除。

是否有一种方法可以按照上述命令链的方式使用Flowable.fromIterable()或zip或merge来实现上述方案？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

javajavakotlinkotlinrx-javarx-kotlin