Merge pull request ReactiveX#5 from g9yuayon/remoting-local

Added immediate checkpoint to avoid unnecessary re-scan of buffer upon b...

Author: benjchristensen

rxjava-contrib/rxjava-netty/src/main/java/rx/netty/experimental/protocol/StringLineCodec.java

@@ -58,6 +58,11 @@ protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) t
             switch(state()) {
                 case NEW_LINE:
                     String line = readFullLine(in);
+
+                    // Immediately checkpoint the progress so that replaying decoder
+                    // will not start over from the beginning of the line when buffer overflows
+                    checkpoint();
+
                     out.add(line);
                     break;
                 case END_OF_LINE: