В Project Reactor у меня есть заданное количество запросов в формате Mono.Чтобы не перегружать целевую службу, мне нужно ограничить количество запросов не более X в секунду и более, чтобы обеспечить максимальное количество ожидающих запросов N, ожидающих завершения.
Ограничение временичасть была легко преобразовать список Monos во Flux и использовать функцию Flux#delayElement
, но я не могу определить второй реквизит.
Как я могу ограничить количество Mono, ожидающих завершения?