org.asynchttpclient.RequestBuilder.addBodyPart()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(5.9k)|赞(0)|评价(0)|浏览(134)

本文整理了Java中org.asynchttpclient.RequestBuilder.addBodyPart方法的一些代码示例,展示了RequestBuilder.addBodyPart的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RequestBuilder.addBodyPart方法的具体详情如下:
包路径:org.asynchttpclient.RequestBuilder
类名称:RequestBuilder
方法名:addBodyPart

RequestBuilder.addBodyPart介绍

暂无

代码示例

代码示例来源:origin: AsyncHttpClient/async-http-client

public Builder addBodyPart(Part part) {
 requestBuilder.addBodyPart(part);
 return this;
}

代码示例来源:origin: AsyncHttpClient/async-http-client

public Future<Response> post(BodyConsumer consumer, Part... parts) throws IOException {
 RequestBuilder r = rebuildRequest(requestBuilder.build());
 r.setMethod("POST");
 for (Part part : parts) {
  r.addBodyPart(part);
 }
 return execute(r, consumer, null);
}

代码示例来源:origin: AsyncHttpClient/async-http-client

public Future<Response> put(Part... parts) throws IOException {
 RequestBuilder r = rebuildRequest(requestBuilder.build());
 r.setMethod("POST");
 for (Part part : parts) {
  r.addBodyPart(part);
 }
 return execute(r, null, null);
}

代码示例来源:origin: AsyncHttpClient/async-http-client

public Future<Response> put(BodyConsumer consumer, Part... parts) throws IOException {
 RequestBuilder r = rebuildRequest(requestBuilder.build());
 r.setMethod("POST");
 for (Part part : parts) {
  r.addBodyPart(part);
 }
 return execute(r, consumer, null);
}

代码示例来源:origin: AsyncHttpClient/async-http-client

public Future<Response> post(Part... parts) throws IOException {
 RequestBuilder r = rebuildRequest(requestBuilder.build());
 r.setMethod("POST");
 for (Part part : parts) {
  r.addBodyPart(part);
 }
 return execute(r, null, null);
}

代码示例来源:origin: AsyncHttpClient/async-http-client

private void sendEmptyFileInputStream(boolean disableZeroCopy) throws Exception {
 File file = getClasspathFile("empty.txt");
 try (AsyncHttpClient c = asyncHttpClient(config().setDisableZeroCopy(disableZeroCopy))) {
  InputStream inputStream = new BufferedInputStream(new FileInputStream(file));
  Request r = post("http://localhost" + ":" + port1 + "/upload")
      .addBodyPart(new InputStreamPart("file", inputStream, file.getName(), file.length(), "text/plain", UTF_8)).build();
  Response res = c.executeRequest(r).get();
  assertEquals(res.getStatusCode(), 200);
 }
}

代码示例来源:origin: AsyncHttpClient/async-http-client

.addBodyPart(new FilePart("file1", testResource1File, "text/plain", UTF_8))
.addBodyPart(new FilePart("file2", testResource2File, "application/x-gzip", null))
.addBodyPart(new StringPart("Name", "Dominic"))
.addBodyPart(new FilePart("file3", testResource3File, "text/plain", UTF_8))
.addBodyPart(new StringPart("Age", "3")).addBodyPart(new StringPart("Height", "shrimplike"))
.addBodyPart(new InputStreamPart("inputStream3", inputStreamFile3, testResource3File.getName(), testResource3File.length(), "text/plain", UTF_8))
.addBodyPart(new InputStreamPart("inputStream2", inputStreamFile2, testResource2File.getName(), testResource2File.length(), "application/x-gzip", null))
.addBodyPart(new StringPart("Hair", "ridiculous")).addBodyPart(new ByteArrayPart("file4",
    expectedContents.getBytes(UTF_8), "text/plain", UTF_8, "bytearray.txt"))
.addBodyPart(new InputStreamPart("inputStream1", inputStreamFile1, testResource1File.getName(), testResource1File.length(), "text/plain", UTF_8))
.build();

代码示例来源:origin: AsyncHttpClient/async-http-client

private void sendFileInputStream(boolean useContentLength, boolean disableZeroCopy) throws Exception {
 File file = getClasspathFile("textfile.txt");
 try (AsyncHttpClient c = asyncHttpClient(config().setDisableZeroCopy(disableZeroCopy))) {
  InputStream inputStream = new BufferedInputStream(new FileInputStream(file));
  InputStreamPart part;
  if (useContentLength) {
   part = new InputStreamPart("file", inputStream, file.getName(), file.length());
  } else {
   part = new InputStreamPart("file", inputStream, file.getName());
  }
  Request r = post("http://localhost" + ":" + port1 + "/upload").addBodyPart(part).build();
  Response res = c.executeRequest(r).get();
  assertEquals(res.getStatusCode(), 200);
 }
}

代码示例来源:origin: AsyncHttpClient/async-http-client

private void sendEmptyFile0(boolean disableZeroCopy) throws Exception {
 File file = getClasspathFile("empty.txt");
 try (AsyncHttpClient c = asyncHttpClient(config().setDisableZeroCopy(disableZeroCopy))) {
  Request r = post("http://localhost" + ":" + port1 + "/upload")
      .addBodyPart(new FilePart("file", file, "text/plain", UTF_8)).build();
  Response res = c.executeRequest(r).get();
  assertEquals(res.getStatusCode(), 200);
 }
}

代码示例来源:origin: org.asynchttpclient/async-http-client-api

public Builder addBodyPart(Part part) {
  requestBuilder.addBodyPart(part);
  return this;
}

代码示例来源:origin: org.asynchttpclient/async-http-client-api

public Future<Response> put(Part... parts) throws IOException {
  RequestBuilder r = rebuildRequest(requestBuilder.build());
  r.setMethod("POST");
  for (Part part : parts) {
    r.addBodyPart(part);
  }
  return execute(r, null, null);
}

代码示例来源:origin: org.asynchttpclient/async-http-client-api

public Future<Response> put(BodyConsumer consumer, Part... parts) throws IOException {
  RequestBuilder r = rebuildRequest(requestBuilder.build());
  r.setMethod("POST");
  for (Part part : parts) {
    r.addBodyPart(part);
  }
  return execute(r, consumer, null);
}

代码示例来源:origin: org.asynchttpclient/async-http-client-api

public Future<Response> post(Part... parts) throws IOException {
  RequestBuilder r = rebuildRequest(requestBuilder.build());
  r.setMethod("POST");
  for (Part part : parts) {
    r.addBodyPart(part);
  }
  return execute(r, null, null);
}

代码示例来源:origin: org.asynchttpclient/async-http-client-api

public Future<Response> post(BodyConsumer consumer, Part... parts) throws IOException {
  RequestBuilder r = rebuildRequest(requestBuilder.build());
  r.setMethod("POST");
  for (Part part : parts) {
    r.addBodyPart(part);
  }
  return execute(r, consumer, null);
}

相关文章