В издателе Flux @ProjectReactor есть очень интуитивно понятный оператор delayElements , который вводит задержку между каждым испускаемым элементом. Скажем, например, следующая треска испускает элемент в секунду. Flux.fromIterable(List.of(1, 2,...

Допустим, у меня есть интерфейс Person , который имеет name наблюдаемых: interface Person { Observable<String> name; } И это реализация: class David implements Person { Observable<String> name =...