Весна 5 Реактор – Испускающий элемент каждые 1 секунду

Я пытаюсь испускать ценность каждую секунду, поскольку

Flux.just(User("A"), User("B"), User("C")).delayElements(Duration.ofSeconds(1)) 

но он испускает все сразу с начальной задержкой в ​​1 секунду. Как я могу ввести задержку для каждого элемента, излучающего?

Flux.just(User("A"), User("B"), User("C")) – это всего лишь один набор элементов, вы, вероятно, хотите что-то вроде

 Flux.fromIterable(listOf(User("A"), User("B"), User("C")) .delayElements(Duration.ofSeconds(1)) 
Intereting Posts
Фильтр rxjava не работает Не удалось выполнить проверку: сбой инструментария из-за «kotlin.UninitializedPropertyAccessException» Android – Невозможно добавить банку, созданную в java8 с kotlin Возможно ли лениво инициализировать свойство и утверждать его? Невозможно сделать API-адрес urlfetch.Fetch в потоке, который не является ни потоком исходного запроса, ни потоком, созданным ThreadManager Возврат из forEachLine Как создать полный экран активности в android программно с помощью kotlin. Android Kotlin – Невозможно планировать уведомление для будущей даты с помощью диспетчера аварийных сигналов Проблема с типом номера телефона в Android Добавление списка подтипов в список супертипов в Котлине Мутатная строка из расширения Как получить выбранный элемент из ListView в Котлине? Ошибка плагина: Котлин бросил исключенное исключение NoReadAccessException Android Build Crashes после подписанной сборки Доступ к Integer.class из Котлина