From c51dd04e8fd08b2539191b976c5e665aff5ce8e1 Mon Sep 17 00:00:00 2001
From: Piotr Janik <piotrjanik@nautilia.pl>
Date: Fri, 16 Oct 2015 09:37:59 +0200
Subject: [PATCH] When chunked response, bytes CRLF is never reached and
 contentSubject.onNext never executed. Termination is handled by ChunkDecoder.

---
 build.gradle                                  |  1 +
 .../ResponseConsumerEventStream.java          | 19 ++++++++-----------
 2 files changed, 9 insertions(+), 11 deletions(-)

diff --git a/build.gradle b/build.gradle
index 0b0c65b..ae806cd 100644
--- a/build.gradle
+++ b/build.gradle
@@ -4,6 +4,7 @@ buildscript {
 }
 
 apply plugin: 'rxjava-project'
+apply plugin: 'java'
 
 dependencies {
     compile 'io.reactivex:rxjava:1.0.+'
diff --git a/src/main/java/rx/apache/http/consumers/ResponseConsumerEventStream.java b/src/main/java/rx/apache/http/consumers/ResponseConsumerEventStream.java
index 8aed85a..cbd9e9b 100644
--- a/src/main/java/rx/apache/http/consumers/ResponseConsumerEventStream.java
+++ b/src/main/java/rx/apache/http/consumers/ResponseConsumerEventStream.java
@@ -1,12 +1,12 @@
 /**
  * Copyright 2014 Netflix, Inc.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  * http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -66,15 +66,12 @@ protected void onByteReceived(ByteBuffer buf, IOControl ioctrl) throws IOExcepti
         }
         while (buf.position() < buf.limit()) {
             byte b = buf.get();
-            if (b == 10 || b == 13) {
-                if (dataBuffer.hasContent()) {
-                    contentSubject.onNext(dataBuffer.getBytes());
-                }
-                dataBuffer.reset();
-            } else {
-                dataBuffer.addByte(b);
-            }
+            dataBuffer.addByte(b);
+        }
+        if (dataBuffer.hasContent()) {
+            contentSubject.onNext(dataBuffer.getBytes());
         }
+        dataBuffer.reset();
     }
 
     @Override