Server Sent event

EventStreamController.java

/**
 * Server sent event dom using Spring webflux.
 * 
 * @author Philippe.DEMANGET
 */
@RestController

@RequestMapping("/event/stream")
public class EventStreamController {
	private Logger logger = LoggerFactory.getLogger(getClass());
	private List<FluxSink<Line>> fluxSinks = new ArrayList<>();

	/**
	 * Simule une alarme toutes les 10 s
	 */
	@Scheduled(fixedRate = 1_000)
	public void sendAlarm() {
		logger.trace("SEND2");
		System.out.println("SEND2");
		fluxSinks.forEach(fluxSink -> {
			fluxSink.next(new Line());
		});
	}

	/**
	 * Flux d'évènements en SSE.
	 * @return
	 */
	//@GetMapping( produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
	@GetMapping( produces = MediaType.TEXT_EVENT_STREAM_VALUE)
	public Flux<Line> stockTransactionEvents() {
		return Flux.create(fluxSink -> {
			fluxSinks.add(fluxSink);
		});
	}


}