Broadcast metrics over websockets using Reactive Streams support