kotlin - 可流动的concatMapSingle，无需预取即可忽略点击，直到处理完成

Question

我想以某种方式处理点击，只要我正在处理发生的某些点击，它们就会被忽略。

我以为可以利用背压来做到这一点，就像这样:

private val clicks = PublishProcessor.create<Unit>()

// ...

clicks
    .onBackpressureDrop()
    .concatMapSingle(::handleClick, 0)

但这会引发错误，因为有一个要求 concatMapSingle需要预取至少一个项目，这使它在完成处理后立即将单击排队并立即处理它，这不是我想要的。我只想在当前没有任何处理的情况下处理单击。

我还有其他运算符可以用来达到预期效果吗？

Answer 1

使用flatMapSingle而不是concatMapSingle可以达到目的，as suggested by akarnokd on GitHub:

flatMap will only fetch the next upstream item if the current one actually completed

最后一个参数是 maxConcurrency，指定 SingleSource的最大 Activity 订阅数:

clicks
    .onBackpressureDrop()
    .flatMapSingle(::handleClick, false, 1)

在这种情况下， flatMapSingle顺序地订阅了那些 Single，因此它不会改变我从 concatMapSingle获得的语义。