Ограничить параллелизм подписки в Reactor

Question

У меня есть служебный класс, централизующий Publisher Reactor для работы с запросами Cassandra:

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

Он работает хорошо, если не работает с обратным давлением, которое заканчивается истощением пула Cassandra, следовательно ошибка. Есть ли способ ограничить параллелизм подписок (поместить их в очередь FIFO) до определенного числа (которое будет соответствовать размеру пула)?

Заранее спасибо.