假设您想在Observable链中插入一个Completable，例如对于每个发出的元素，都有一个Completable运行并阻塞直到其完成，您会选择哪个选项？（这里的Completable.complete()只是为了举例） .flatMap { Completable.complete...

我有一个场景，需要定期调用API来检查结果。 我使用Flowable.interval创建一个间隔函数来调用API。 然而，我遇到了背压问题。 在下面的示例中，每个间隔时间都会创建一个新的单一对象。 期望的效果是仅在没有进行中的调用时才调用API。 Flowable.interval(1,...