netflux-hot.java

//our movie theatre
//each scene will play for 2 seconds
Flux<String> movieTheatre = Flux.fromStream(() -> getMovie())
                                .delayElements(Duration.ofSeconds(2))
                               .share();

// you start watching the movie
movieTheatre.subscribe(scene -> System.out.println("You are watching " + scene));

//I join after sometime
Thread.sleep(5000);
movieTheatre.subscribe(scene -> System.out.println("Vinsguru is watching " + scene));