关于Single.defer()代码块未执行的技术问题求助

我一眼就看出问题所在了——你的RxJava流组合方式不对，导致documentRepository.getDocuments()返回的Single根本没有被订阅，自然Single.defer里的代码不会执行。

问题根源分析 #

在buildUseCaseObservable的flatMap中，你遍历reports并逐个调用getDocuments()，但仅仅是创建了Single对象，却没有把这些Single纳入到RxJava的流中。RxJava的Single属于冷流：只有当存在订阅者的时候，它内部的逻辑（包括defer里的代码）才会被触发。而你直接跳过了订阅步骤，直接返回了Single.just(finalReports.toList())，这时候那些getDocuments()的Single完全没被执行，finalReports也会是空的。

解决方案 #

你需要用RxJava的操作符来组合这些Single，确保每个getDocuments()都被订阅执行。可以用Observable.fromIterable遍历reports，再通过flatMapSingle处理每个report的文档获取逻辑，最后用toList()收集结果。修改后的代码如下：

override fun buildUseCaseObservable(params: Void?): Single<List<Report>> {
    return reportRepository
        .getReports()
        .flatMapObservable { Observable.fromIterable(it) }
        .flatMapSingle { report ->
            documentRepository.getDocuments(report.id!!)
                .map { documents ->
                    Report(report.id, report.name, report.status, report.dateCreated, documents)
                }
        }
        .toList()
}

代码修改说明 #

• 用flatMapObservable把List<Report>转成Observable<Report>，这样可以逐个处理每个report
• 用flatMapSingle来关联每个report对应的getDocuments()请求，这个操作符会自动订阅每个返回的Single，并把结果传递下去
• 最后toList()会把所有处理后的Report收集成一个List，转成Single<List<Report>>返回

这样一来，每个getDocuments()的Single都会被订阅，Single.defer里的代码就会正常执行了。

额外提示 #

• 注意report.id!!的使用，如果report.id可能为null，建议添加空值判断，避免抛出NullPointerException
• 如果需要并行处理这些getDocuments()请求，可以考虑用flatMapSingle的并发参数，比如flatMapSingle(10) { ... }来控制并发数

内容的提问来源于stack exchange，提问作者Karl Jamoralin