java - 来自 Vertx Web 客户端响应正文的 react 流发布者

Question

我正在尝试为 Vert.x web-client 编写一个包装器使用reactivestreams中的Publisher从服务器加载响应正文:

import org.reactivestreams.Publisher;
import io.vertx.reactivex.ext.web.client.WebClient;

interface Storage {
  Publisher<ByteBuffer> load(String key);
}

class WebStorage implements Storage {
  private final WebClient client;

  public WebStorage(final WebClient client) {
    this.client = client;
  }

  @Override
  public Publisher<ByteBuffer> load(final String key) {
    return client.get(String.format("https://myhost/path?query=%s", key))
      .rxSend()
      .toFlowable()
      .map(resp -> ByteBuffer.wrap(resp.body().getBytes()));
  }
}

此解决方案不正确，因为它通过 getBytes() 调用以阻塞方式读取所有正文字节。

是否可以按 block 读取来自 Vert.x WebClient 的响应并将其转换为 Publisher (或 Rx Flowable)？

Answer 1

Vert.x Web 客户端并非设计用于传输响应正文。它按设计缓冲内容。

如果您想流式传输内容，可以使用更灵活的底层 HTTP 客户端。