Hands-On Reactive Programming in Spring 5

Exposing the SSE endpoint

To expose the SSE endpoint, we need a REST controller that is autowired with the TemperatureSensor instance. The following code shows the controller, which utilizes RxSeeEmitter:

@RestControllerpublic class TemperatureController {   private final TemperatureSensor temperatureSensor;                // (1)   public TemperatureController(TemperatureSensor temperatureSensor) {      this.temperatureSensor = temperatureSensor;   }   @RequestMapping(      value = "/temperature-stream",      method = RequestMethod.GET)   public SseEmitter events(HttpServletRequest request) {      RxSeeEmitter emitter = new RxSeeEmitter();                     // (2)      temperatureSensor.temperatureStream()                          // (3)         .subscribe(emitter.getSubscriber());                        // (4)      return emitter;                                                // (5)   }}

The TemperatureController ...