Hands-On Reactive Programming with Reactor

Broadcasting

In networking, broadcasting is defined as simultaneous event publishing to multiple receivers. In terms of Reactive Streams, this means simultaneous event publishing to multiple subscribers. Until now, we have subscribed to cold publishers, where each subscription generates a new series of events. We have even subscribed to hot publishers, where the publisher keeps pushing events without waiting for a subscriber. Each subscriber gets the same event as soon as it is generated. A hot publisher may look like a broadcasting event, but there is a key difference with regard to the start of the event generation stream. Reactor allows us to create a ConnecatableFlux, capable of waiting for n subscribers before starting event generation. ...