reactive-streams-for-java-developers
reactive-streams-for-java-developers copied to clipboard
Single stream broadcasting results to all web socket clients?
Looks like this code will materialize the full stream for each new web socket client, meaning duplicates of each processing step.
It can be expensive in real applications.
Is there a way to have just 1 stream and broadcast results to all web socket clients?