Example using RxJava in Ratpack to publish WebSockets - View it on GitHub