0
教程/实施例表明:为什么netty客户端返回Observable <Observable <ByteBuf>>而不是Observable <ByteBuf>?
Observable<HttpClientResponse<ByteBuf>> httpGet =
RxNetty.createHttpGet("http://xxxx");
Observable<Observable<ByteBuf>> byteBuffers =
httpGet.map(HttpClientResponse::getContent);
我明白字节可能会在组块因此我明白的Observable<ByteBuf>
的需要。
但为什么要Observable<HttpClientResponse>
?为什么不只是一个HttpClientResponse
提供Observable<ByteBuf>
?或者实际上它只是一个Single<HttpClientResponse>
裹在Observable
使api更流利?但在这种情况下,有一些文件?