Как ограничить количество моно, ожидающих завершения? - PullRequest
0 голосов
/ 05 марта 2019

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

Ограничение временичасть была легко преобразовать список Monos во Flux и использовать функцию Flux#delayElement, но я не могу определить второй реквизит.

Как я могу ограничить количество Mono, ожидающих завершения?

...