android - flatMapFirst : flatMap which adds new observable only if the previous one ended

Question

如何实现类似于 flatMap 的 flatMapFirst 运算符，但只有在前一个结束时才添加新的 observable？如果前一个仍在运行，它只会忽略新的 observable。如何在 RxJava 2 中实现？

它已经存在于培根中 - flatMapFirst在开菲尔中 - flatMapFirst .

Answer 1

您不需要新的运算符，而是现有运算符的组合:

source.onBackpressureLatest().flatMap(function, 1)

FlatMap 将一次运行 1 个内部源，如果在 flatMap 运行 1 个内部源时没有需求，onBackpressureLatest 将继续丢弃外部源值(最新的除外)。

如果您不想继续使用最新的源代码，请考虑使用 onBackpressureDrop。