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