android - 分块流式传输不符合预期 Retrofit+RxJava

Question

@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 -> events(responseBody.source()));
}

public static Observable<String> events(BufferedSource source) {
    return Observable.create(subscriber -> {
        try {
            while (!source.exhausted()) {
                subscriber.onNext(source.readUtf8Line());
            }
        } catch (IOException e) {
            e.printStackTrace();
            subscriber.onError(e);
        }
        subscriber.onCompleted();
    });
}

除非所有 block 都完成，否则不会调用 events() 方法。

但是分块流应该逐 block 传送，这似乎并没有发生。

我尝试过使用和不使用 API 的 @Streaming 注释，但行为是相同的。

我用过Android Retrofit 2 + RxJava: listen to endless stream作为我实现的引用

Answer 1

好的伙计们，我找到了答案。这是因为我正在使用 Body 属性登录

logging.setLevel(HttpLoggingInterceptor.Level.BODY);

因此，由于记录器正在等待整个 body 打印它，因此它的行为与问题中提到的方式相同。

引用:Square's Retrofit response parsing logic: streaming?