Example RIPC server wiring using Reactor

ExampleReactorCode.java

ReactorTcpServer.listen(3000, ByteBuf.class)
                .log("connection")
                .consume(conn -> conn.out(conn.in().log("in"))
                                     .log("confirmation")
                                     .consume(buf -> LOG.info("write confirmed: {}", buf)));