У меня есть webflux, который получает данные из потока событий, но я хочу, чтобы он находился в более или менее стабильном состоянии (то есть события перестали течь в течение нескольких миллисекунд), что-то вроде оператора debounce в RxJS.
Кажется, я не могу найти ничего подобного в API.
Эквивалентом webflux является метод bufferTimeout
.bufferTimeout(20, Duration.ofSeconds(1))
Преимущество этого метода заключается в том, что вы получаете все события, а не только последнее, что debounce делает в виде списка.
debounce