ZT
thank you
@GetMapping(path = "/read2", produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
public Flux<String> read2() {
return Flux.create(sink -> {
IntStream.rangeClosed(0, 5).boxed().forEach(i -> {
sink.next(String.valueOf(i));
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
});
});
}
