Как сделать HOSTP POST строки с rxSendStream из io.vertx.reactivex.ext.web.client.WebClient

Question

Я новичок в Vertx и Rx Java. Я хочу сделать HOSTP POST, но мой контент является строкой. Вот мой код:

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

и body может быть любым из следующих:

• Flowable<Buffer> body или
• Observable<Buffer> body или
• 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());
   });