code: private static Interceptor<ByteBuf, ByteBuf> sendHello() {
          return in -> newConnection -> newConnection.writeString(Observable.just("Hello\n"))
                                                     .concatWith(in.handle(newConnection));
      }
docs: Sends a hello on accepting a new connection.