* Fix all their Checkstyle violations * Expose convenient `Consumer<Flux<Message<?>>>` for RSocket consumer