Adding a short-circuit interception sample.

Author: Nitesh Kant

ripc-transport-netty4-examples/src/main/java/io/ripc/transport/netty4/tcp/TcpServerSample.java

@@ -8,6 +8,8 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.concurrent.atomic.AtomicLong;
+
 import static java.nio.charset.Charset.defaultCharset;
 import static rx.RxReactiveStreams.*;
 
@@ -22,9 +24,23 @@ public static TcpInterceptor<ByteBuf, ByteBuf, ByteBuf, ByteBuf> log() {
         };
     }
 
+    public static TcpInterceptor<ByteBuf, ByteBuf, ByteBuf, ByteBuf> shortCircuitAltConnection() {
+        return handler -> {
+            final AtomicLong connCounter = new AtomicLong();
+            return input -> {
+                if (connCounter.incrementAndGet() % 2 == 0) {
+                    logger.error("Short-circuiting further processing.");
+                    return input.write(Publishers.just(Unpooled.buffer().writeBytes("Go Away!!! \n".getBytes())));
+                }
+                return handler.handle(input);
+            };
+        };
+    }
+
     public static void main(String[] args) {
         Netty4TcpServer.<ByteBuf, ByteBuf>create(0)
                        .intercept(log())
+                       .intercept(shortCircuitAltConnection())
                        .start(connection ->
                                       toPublisher(toObservable(connection)
                                                           .flatMap(byteBuf -> {