title: Chunked streaming not behaving as expected Retrofit+RxJava
body: <pre><code>@GET("poll/session/{sessionId}/details")
  Observable getSessionDetails(@Path("sessionId") String sessionId);
  
  @GET("poll/session/{sessionId}/details")
  @Streaming
  Observable getSessionDetails(@Path("sessionId") String sessionId);
  
  @Override
  public Observable getSessionDetails(String sessionId) {
  return sessionAPI.getSessionDetails(sessionId)
  .flatMap(responseBody -&gt; events(responseBody.source()));
  }
  
  public static Observable&lt;String&gt; events(BufferedSource source) {
      return Observable.create(subscriber -&gt; {
          try {
              while (!source.exhausted()) {
                  subscriber.onNext(source.readUtf8Line());
              }
          } catch (IOException e) {
              e.printStackTrace();
              subscriber.onError(e);
          }
          subscriber.onCompleted();
      });
  }
  </code></pre>
  
  <p>The events() method does not get called unless all the chunks are done.</p>
  
  <p>But the chunked streams are expected to be delivered chunk by chunk, which does not seem to be happening.</p>
  
  <p>I have tried with and without the @Streaming annotation to the API, yet the behaviour is same.</p>
  
  <p>I had used <a href="https://stackoverflow.com/questions/36603368/android-retrofit-2-rxjava-listen-to-endless-stream">Android Retrofit 2 + RxJava: listen to endless stream</a> as a reference to do my implementation</p>