Eu quero lidar com cliques de forma que eles sejam ignorados desde que eu esteja processando algum clique que ocorre

Eu pensei que poderia fazê-lo utilizando a contrapressão, assim:

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

// ...

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

Mas isso gera um erro, porque há um requisito queconcatMapSingle precisa buscar previamente pelo menos um item, o que faz com que o clique fique na fila e processe-o imediatamente após o término do processamento, o que não é o que desejo. Quero processar o clique apenas se não houver processamento no momento.

Existe algum outro operador que eu possa usar para obter o efeito desejad