Я точно не знаю, почему одна функция работает, а другая не работает с использованием функций пружинного облака 3.1.0.BUILD-SNAPSHOT
Оба URL-адреса были протестированы с помощью следующей команды
curl -N -H "Accept:text/event-stream" http://...
Это излучение, как и ожидалось, с использованием протокола SSE
@Bean
public Supplier<Flux<String>> sse() {
return () -> Flux.just("A", "B", "C")
.repeat(5);
}
Но это ничего не излучает
@Bean
public Supplier<Flux<String>> echo() {
return () -> Flux.interval(Duration.ofSeconds(1))
.map(x -> String.format("Tick:%s", x))
.log();
}