本文整理了Java中io.vertx.reactivex.ext.web.client.HttpRequest.rxSendForm()方法的一些代码示例，展示了HttpRequest.rxSendForm()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。HttpRequest.rxSendForm()方法的具体详情如下：
包路径：io.vertx.reactivex.ext.web.client.HttpRequest
类名称：HttpRequest
方法名：rxSendForm

HttpRequest.rxSendForm介绍

暂无

代码示例

代码示例来源：origin: io.knotx/knotx-databridge-adapter-http

private Single<HttpResponse<Buffer>> callService(
  Pair<ClientRequest, HttpDataSourceSettings> serviceData, HttpMethod method) {
 final Single<HttpResponse<Buffer>> httpResponse;
 final ClientRequest serviceRequest = serviceData.getLeft();
 final HttpDataSourceSettings serviceMetadata = serviceData.getRight();
 final HttpRequest<Buffer> request = webClient
   .request(method, serviceMetadata.getPort(), serviceMetadata.getDomain(),
     serviceRequest.getPath());
 updateRequestQueryParams(request, serviceMetadata);
 updateRequestHeaders(request, serviceRequest, serviceMetadata);
 overrideRequestHeaders(request, serviceMetadata);
 if (!serviceRequest.getFormAttributes().isEmpty()) {
  httpResponse = request.rxSendForm(serviceRequest.getFormAttributes());
 } else {
  httpResponse = request.rxSend();
 }
 return httpResponse;
}

代码示例来源：origin: io.knotx.acme/acme-forms-adapter-http

private Single<HttpResponse<Buffer>> callService(
  Pair<ClientRequest, HttpFormsSettings> serviceData, HttpMethod method) {
 final Single<HttpResponse<Buffer>> httpResponse;
 final ClientRequest serviceRequest = serviceData.getLeft();
 final HttpFormsSettings serviceMetadata = serviceData.getRight();
 final HttpRequest<Buffer> request = webClient
   .request(method, serviceMetadata.getPort(), serviceMetadata.getDomain(),
     serviceRequest.getPath());
 updateRequestQueryParams(request, serviceMetadata);
 updateRequestHeaders(request, serviceRequest, serviceMetadata);
 overrideRequestHeaders(request, serviceMetadata);
 if (!serviceRequest.getFormAttributes().isEmpty()) {
  httpResponse = request.rxSendForm(serviceRequest.getFormAttributes());
 } else {
  httpResponse = request.rxSend();
 }
 return httpResponse;
}

代码示例来源：origin: Cognifide/knotx

private Single<HttpResponse<Buffer>> callService(
  Pair<ClientRequest, ServiceSettings> serviceData, HttpMethod method) {
 final Single<HttpResponse<Buffer>> httpResponse;
 final ClientRequest serviceRequest = serviceData.getLeft();
 final ServiceSettings serviceMetadata = serviceData.getRight();
 final HttpRequest<Buffer> request = webClient
   .request(method, serviceMetadata.getPort(), serviceMetadata.getDomain(),
     serviceRequest.getPath());
 updateRequestQueryParams(request, serviceMetadata);
 updateRequestHeaders(request, serviceRequest, serviceMetadata);
 overrideRequestHeaders(request, serviceMetadata);
 if (!serviceRequest.getFormAttributes().isEmpty()) {
  httpResponse = request.rxSendForm(serviceRequest.getFormAttributes());
 } else {
  httpResponse = request.rxSend();
 }
 return httpResponse;
}

代码示例来源：origin: Cognifide/knotx

private void testPostRequest(VertxTestContext context, Vertx vertx, String url,
  Consumer<HttpResponse<Buffer>> expectedResponse) {
 WebClient client = WebClient.create(vertx);
 MultiMap formData = MultiMap.caseInsensitiveMultiMap();
 formData.add("a", "b");
 Single<HttpResponse<Buffer>> httpResponseSingle = client
   .post(KnotxServerRoutingTest.KNOTX_SERVER_PORT,
     KnotxServerRoutingTest.KNOTX_SERVER_ADDRESS,
     url)
   .rxSendForm(formData);
 subscribeToResult_shouldSucceed(context, httpResponseSingle, expectedResponse);
}

代码示例来源：origin: Cognifide/knotx

@Test
@KnotxApplyConfiguration("io/knotx/server/test-server-csrf.json")
public void whenDoPostSecureWithoutCSRF_expectForbidden(
  VertxTestContext context, Vertx vertx) {
 createPassThroughKnot(vertx, "test-splitter");
 createPassThroughKnot(vertx, "test-assembler");
 createSimpleKnot(vertx, "some-knot", "test", null);
 MultiMap body = MultiMap.caseInsensitiveMultiMap().add("field", "value");
 WebClient client = WebClient.create(vertx);
 Single<HttpResponse<Buffer>> httpResponseSingle = client
   .post(KNOTX_SERVER_PORT, KNOTX_SERVER_ADDRESS, "/content/local/simple.html")
   .rxSendForm(body);
 subscribeToResult_shouldSucceed(context, httpResponseSingle, result -> {
  assertEquals(HttpResponseStatus.FORBIDDEN.code(), result.statusCode());
 });
}

代码示例来源：origin: Cognifide/knotx

@Test
@KnotxApplyConfiguration("io/knotx/server/test-server-csrf.json")
public void whenDoPostPublicWithoutCSRF_expectOk(
  VertxTestContext context, Vertx vertx) {
 createPassThroughKnot(vertx, "test-splitter");
 createPassThroughKnot(vertx, "test-assembler");
 createSimpleKnot(vertx, "some-knot", "test", null);
 MultiMap body = MultiMap.caseInsensitiveMultiMap().add("field", "value");
 WebClient client = WebClient.create(vertx);
 Single<HttpResponse<io.vertx.reactivex.core.buffer.Buffer>> httpResponseSingle = client
   .post(KNOTX_SERVER_PORT, KNOTX_SERVER_ADDRESS, "/content/local/public.html")
   .rxSendForm(body);
 subscribeToResult_shouldSucceed(context, httpResponseSingle, resp -> {
  assertEquals(HttpResponseStatus.OK.code(), resp.statusCode());
 });
}