Блог

Я пытаюсь протестировать потоковую передачу потока с задержкой 1000 миллис для каждого элемента.

 @Get(value = "/carts/reactive", produces = MediaType.APPLICATION_JSON_STREAM)
public Flux<Cart> getCartsReactive() {
     return Flux.range(1, 10)
            .map(integer -> Cart.builder().name("cart"   integer).build())
            .delayElements(Duration.ofMillis(1000))
            .doOnNext(cart -> log.info("Returning Flux of cart: "  cart));
}
 

Когда я захожу в службу, я не получаю ответа в течение 10 секунд и получаю ответный блог.

 curl http://localhost:7070/carts/reactive

{"name":"cart1"}{"name":"cart2"}{"name":"cart3"}{"name":"cart4"}{"name":"cart5"}{"name":"cart6"}{"name":"cart7"}{"name":"cart8"}{"name":"cart9"}{"name":"cart10"}
 

Это ошибка? Почему он не выбрасывает 1 корзину каждую секунду?

В вашем коде, который вы написали, нет ничего плохого — вот полный проект с использованием micronaut reactor с точно таким кодом в контроллере:

https://github.com/berry120/micronaut-reactive-demo

Он производит элементы по одному, как и ожидалось, с задержкой в одну секунду:

Вы можете сравнить этот проект со своим собственным, чтобы увидеть, какую конфигурацию / код вы можете пропустить, что мешает ему работать должным образом. Я вообще не делал ничего особенного с вышеупомянутым проектом — он был создан исключительно на основе Micronaut initializr с включенным дополнением reactor.

Обратите внимание, что вы должны настроить модуль micronaut-reactor ( implementation("io.micronaut.reactor:micronaut-reactor") ), а не просто включать reactor в качестве зависимости от третьей стороны, в противном случае это может вызвать проблемы.