假设您想在Observable链中插入一个Completable,例如对于每个发出的元素,都有一个Completable运行并阻塞直到其完成,您会选择哪个选项?(这里的Completable.complete()只是为了举例) .flatMap { Completable.complete...
我有一个场景,需要定期调用API来检查结果。 我使用Flowable.interval创建一个间隔函数来调用API。 然而,我遇到了背压问题。 在下面的示例中,每个间隔时间都会创建一个新的单一对象。 期望的效果是仅在没有进行中的调用时才调用API。 Flowable.interval(1,...