我有一个公用事业类集中React堆的 Publisher 处理cassandra查询的步骤：

public Mono<ResultSet> execute(Statement statement) {
    return Mono.defer(() -> Mono.fromFuture(FutureConverter
            .toCompletableFuture(session.executeAsync(statement)))
            .publishOn(Schedulers.elastic()));
}

它工作得很好，希望它不处理背压，这最终导致Cassandra池耗尽，因此一个错误。有没有办法将订阅的并发性（将它们放入fifo队列）限制为给定的数目（与池的大小相匹配）？
提前谢谢。