android - 两个单链rxjava2

Question

我有两个单例:

getFile.execute(id)
                .observeOn(AndroidSchedulers.mainThread())
                .subscribeOn(Schedulers.io())
                .subscribeBy(
                        onSuccess = { fileInfo ->
                            with(fileInfo) {
                                update(id, url, email)
                            }
                        },
                        onError = {
                            view?.showError()
                        }
                )

和:

private fun update(id: Long, url: String, email: String) {
        save.execute(FileInfo(id, url, email))
                .observeOn(AndroidSchedulers.mainThread())
                .subscribeOn(Schedulers.io())
                .subscribeBy(
                        onSuccess = {
                            view?.onUpdateSuccess()
                        },
                        onError = {
                            view?.showUpdateError()
                        }
                )
    }

您可以从第一个结果中看到第二个一次性使用数据。我可以将这两个 Single 组合成一个链吗？

Answer 1

您可以使用 flatMap 链接 Single。

getFile.execute(id)
    .flatMap({fileInfo -> save.execute(fileInfo)})
    .subscribeOn(Schedulers.io())
            .subscribeBy(
                    onSuccess = {
                        view?.onUpdateSuccess()
                    },
                    onError = {
                        view?.showUpdateError()
                    }
            )