WebFlux系列(二) Server-Sent Events

package com.example.webfluxserver;

import lombok.extern.log4j.Log4j2;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;

import java.time.Duration;

@Log4j2
@SpringBootApplication
public class WebfluxServerApplication extends BaseApplication{
    public static void main(String[] args) { SpringApplication.run(WebfluxServerApplication.class, args); }
    @RestController
    class EmployeeController{

        @GetMapping(value = "sse",produces = MediaType.TEXT_EVENT_STREAM_VALUE)
        public Flux<String> sse1(){
            return Flux.interval(Duration.ofMillis(1000)).map(val ->val.toString());
        }
    }
}