2016-11-27 30 views
0

チュートリアル/例が示していますなぜnettyクライアントはObservable <ByteBuf>の代わりにObservable <Observable <ByteBuf>>を返しますか?

Observable<HttpClientResponse<ByteBuf>> httpGet = 
              RxNetty.createHttpGet("http://xxxx"); 
Observable<Observable<ByteBuf>> byteBuffers = 
            httpGet.map(HttpClientResponse::getContent); 

私はバイト、したがって、私はObservable<ByteBuf>の必要性を理解チャンクで来るかもしれないことを理解しています。

しかし、なぜObservable<HttpClientResponse>?なぜObservable<ByteBuf>を提供する単一のHttpClientResponseだけではないのですか?実際にはがObservableにラップされているため、APIをより流暢にすることができますか?この場合、いくつかの文書がありますか?

答えて

0

はいこれは本質的にSingle<HttpClientResponse>です。これらのAPIは、SingleがRxJavaに導入される前に作成されたため、使用しません。Single