Flux: custom emitter simulation

custom_flux_emitter.java

    /**
     * Custom emitter.
     */
    @GetMapping(value = "/custom-emitter", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux<String> getCustomEmitter() {
        EmitterProcessor<String> hotSource = EmitterProcessor.create();

        Flux<String> hotFlux = hotSource.publish().autoConnect();

//        hotFlux.subscribe(d -> System.out.println("Subscriber 1 to Hot Source received: "+d));
//        hotFlux.subscribe(d -> System.out.println("Subscriber 2 to Hot Source received: "+d));

        // simulating different data producer:
        new Thread(() -> {
            int i = 0;
            do {
                System.out.print(".");
                
                hotSource.onNext("A"+String.valueOf(i++));  // it can add any data to the flux from anywhere
                
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                }
            } while (true);
        }).start();

        return hotFlux;
    }