Spring boot webflux TEXT_EVENT_STREAM_VALUE不工作

Question

我正在使用spring-boot和依赖关系spring-boot-starter-webflux，我想在浏览器上每秒获得一个数据，当我使用spring-boot版本2.1.4时，代码正常工作，但2.1.5或更高版本不工作，我将在10秒后获得所有数据，而不是每秒获得一个数据

I want to get the reason,or others i should  do 


I find spring-boot update the dependency of netty in 2.1.5,
so if i add the dependency in my pom.xml with 
<dependency>
    <groupId>io.projectreactor.netty</groupId>
    <artifactId>reactor-netty</artifactId>
    <version>0.8.8.RELEASE</version>
 </dependency>

it working


@RestController
@RequestMapping("/demo")
public class DemoController {
    // just get a string per second
    @GetMapping(value = "",produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux<String>  getMsg(){
       return Flux.fromStream(new Random().ints(10).mapToObj(intStream -> 
       {
           try {
               TimeUnit.SECONDS.sleep(1);
           } catch (InterruptedException e) {
               e.printStackTrace();
           }
           return "this is data "+intStream;
       }));
    }
}

Answer 1

我相信这会达到你想要的目的。

@GetMapping(value = "",produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<String> getMsg(){
    return Flux.fromStream(new Random()
            .ints(10)
            .mapToObj(value -> "this is data " + value))
            .delayElements(Duration.ofSeconds(1));
}