从 combineLatest Observables 中跳过错误值

Question

我正在组合一些 Observable，我想跳过返回错误的任何人，以便 Observable 可以完全运行

let observable = Observable.combineLatest(
            remoteRepository.getxx1(),
            remoteRepository.getxx2(),
            remoteRepository.getxx3()
        ) { [weak self] xx1, xx2, xx3 in

            guard let self = self else { return }

        }

        runObservable(observable: observable)

getxx3() 给出错误，因此该过程未完成。如果出现错误，我该如何继续

Answer 1

如果您对错误是什么根本不感兴趣，那么您可以捕获错误并在每个子可观察对象上发出完成的事件。像这样：

Observable.combineLatest(
    remoteRepository.getxx1().catch { _ in .empty() },
    remoteRepository.getxx2().catch { _ in .empty() },
    remoteRepository.getxx3().catch { _ in .empty() }
)

使用上述方法，如果任何 getter 发出错误，catch 运算符将捕获它，empty() 运算符将发出一个已完成的事件。这将允许其他 observables 完成他们的工作并完成。