rx-java2 - 如何使用 io.vertx.reactivex.ext.web.client.WebClient 的 rxSendStream 对字符串进行 Http POST

Question

我是 Vertx 和 Rx Java 的新手。我想做一个 Http POST ，但我的内容是一个字符串。这是我的代码：

Single<HttpResponse<Buffer>> single = webClient
  .post(apiUrl)          
  .rxSendStream(body);

和 body 可以是以下任何一种：

• Flowable<Buffer>身体或
• Observable<Buffer>身体或
• Buffer身体

我的问题是如何将 body 转换为上述任何类型

Answer 1

最简单的方法是这样的：

WebClient webClient = WebClient.create(vertx);
String body  = "";
webClient.post(apiUrl)
   .rxSendBuffer(Buffer.buffer(body))
   .subscribe(resp -> {
     System.out.println(resp.body().toString());
   });