<Flowable concatMapSingle without prefetch> I want...

# stackoverflow

[user]

Flowable concatMapSingle without prefetch
I want to handle clicks in such a way that they are ignored as long as I'm doing processing of some click that occurred.

I thought I could do it by utilizing the backpressure, like this:

private val clicks = PublishProcessor.create()

// ...

clicks
.onBackpressureDrop()
.concatMapSingle({
// process the click event
}, 0)


But apparently there's a requirement that concatMapSingle needs to prefetch at least one item, which makes it queue the click and process it...