在RxJS中,可观测实例的catch方法和onErrorResumeNext方法似乎几乎没有区别,除了onErrorResumeNext将原始可观测参数与可观测参数连接起来之外,无论是否发生错误。因为在出现错误的情况下,onErrorResumeNext的工作方式与catch完全相同:
// Both onError and onCatch
我现在正在尝试实现一个扩展函数(只是因为它对我来说更容易),它能够延迟正常的项目发射和错误。现有的延迟操作员只延迟正常的项目发射,错误被尽快交付。我创建了一个BehaviourSubject,它在活动状态发生变化时发出活动的状态和片段。然后我创建了一个延迟运算符,如下所示:
fun <T> Flowable<