android–Chunked流媒体表现不如预期Retrofit RxJava

概述@GET("poll/session/{sessionId}/details")ObservablegetSessionDetails(@Path("sessionId")StringsessionId);@GET("poll/session/{sessionId}/details")@StreamingObservablegetSessionDetails(@Path("sessionId")String

@GET("poll/session/{sessionID}/details")Observable getSessionDetails(@Path("sessionID") String sessionID);@GET("poll/session/{sessionID}/details")@StreamingObservable getSessionDetails(@Path("sessionID") String sessionID);@OverrIDepublic 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();    });}

除非完成所有块,否则不会调用events()方法.

但是,大块的流预计会被大块交付,这似乎并没有发生.

我已尝试使用和不使用@Streaming注释到API,但行为是相同的.

我曾使用Android Retrofit 2 + RxJava: listen to endless stream作为参考来实现我的实现

解决方法:

好吧,我找到了答案.这是因为我正在使用Body属性进行记录

logging.setLevel(httpLoggingInterceptor.Level.BODY);

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

参考：Square’s Retrofit response parsing logic: streaming?

总结

以上是内存溢出为你收集整理的android – Chunked流媒体表现不如预期Retrofit RxJava全部内容，希望文章能够帮你解决android – Chunked流媒体表现不如预期Retrofit RxJava所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。