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

RequestBody.writeTo介绍

[英]Writes the content of this request to out.
[中]将此请求的内容写入out。

代码示例

代码示例来源：origin: square/retrofit

@Override public void writeTo(BufferedSink sink) throws IOException {
  delegate.writeTo(sink);
 }
}

代码示例来源：origin: com.squareup.retrofit2/retrofit

@Override public void writeTo(BufferedSink sink) throws IOException {
  delegate.writeTo(sink);
 }
}

代码示例来源：origin: amitshekhariitbhu/Fast-Android-Networking

private RequestBody forceContentLength(final RequestBody requestBody) throws IOException {
  final Buffer buffer = new Buffer();
  requestBody.writeTo(buffer);
  return new RequestBody() {
    @Override
    public MediaType contentType() {
      return requestBody.contentType();
    }
    @Override
    public long contentLength() {
      return buffer.size();
    }
    @Override
    public void writeTo(BufferedSink sink) throws IOException {
      sink.write(buffer.snapshot());
    }
  };
}

代码示例来源：origin: square/retrofit

@Override public String convert(T value) throws IOException {
  Buffer buffer = new Buffer();
  delegate.convert(value).writeTo(buffer);
  return buffer.readUtf8();
 }
}

代码示例来源：origin: square/okhttp

@Override public void writeTo(BufferedSink sink) throws IOException {
  BufferedSink gzipSink = Okio.buffer(new GzipSink(sink));
  body.writeTo(gzipSink);
  gzipSink.close();
 }
};

代码示例来源：origin: jeasonlzy/okhttp-OkGo

/** 重写进行写入 */
@Override
public void writeTo(BufferedSink sink) throws IOException {
  CountingSink countingSink = new CountingSink(sink);
  BufferedSink bufferedSink = Okio.buffer(countingSink);
  requestBody.writeTo(bufferedSink);
  bufferedSink.flush();
}

代码示例来源：origin: pinguo-zhouwei/MZBannerView

private static String bodyToString(final RequestBody request){
  try {
    final RequestBody copy = request;
    final Buffer buffer = new Buffer();
    if(copy != null)
      copy.writeTo(buffer);
    else
      return "";
    return buffer.readUtf8();
  }
  catch (final IOException e) {
    return "did not work";
  }
}

代码示例来源：origin: amitshekhariitbhu/Fast-Android-Networking

@Override
  public void writeTo(BufferedSink sink) throws IOException {
    BufferedSink gzipSink = Okio.buffer(new GzipSink(sink));
    body.writeTo(gzipSink);
    gzipSink.close();
  }
};

代码示例来源：origin: amitshekhariitbhu/Fast-Android-Networking

@Override
public void writeTo(BufferedSink sink) throws IOException {
  if (bufferedSink == null) {
    bufferedSink = Okio.buffer(sink(sink));
  }
  requestBody.writeTo(bufferedSink);
  bufferedSink.flush();
}

代码示例来源：origin: jeasonlzy/okhttp-OkGo

private void bodyToString(Request request) {
    try {
      Request copy = request.newBuilder().build();
      RequestBody body = copy.body();
      if (body == null) return;
      Buffer buffer = new Buffer();
      body.writeTo(buffer);
      Charset charset = getCharset(body.contentType());
      log("\tbody:" + buffer.readString(charset));
    } catch (Exception e) {
      OkLogger.printStackTrace(e);
    }
  }
}

代码示例来源：origin: JessYanCoding/ProgressManager

@Override
public void writeTo(BufferedSink sink) throws IOException {
  if (mBufferedSink == null) {
    mBufferedSink = Okio.buffer(new CountingSink(sink));
  }
  try {
    mDelegate.writeTo(mBufferedSink);
    mBufferedSink.flush();
  } catch (IOException e) {
    e.printStackTrace();
    for (int i = 0; i < mListeners.length; i++) {
      mListeners[i].onError(mProgressInfo.getId(), e);
    }
    throw e;
  }
}

代码示例来源：origin: facebook/stetho

@Nullable
@Override
public byte[] body() throws IOException {
 RequestBody body = mRequest.body();
 if (body == null) {
  return null;
 }
 OutputStream out = mRequestBodyHelper.createBodySink(firstHeaderValue("Content-Encoding"));
 BufferedSink bufferedSink = Okio.buffer(Okio.sink(out));
 try {
  body.writeTo(bufferedSink);
 } finally {
  bufferedSink.close();
 }
 return mRequestBodyHelper.getDisplayBody();
}

代码示例来源：origin: Rukey7/MvpApp

@Override
  public Response intercept(Chain chain) throws IOException {
    final Request request = chain.request();
    Buffer requestBuffer = new Buffer();
    if (request.body() != null) {
      request.body().writeTo(requestBuffer);
    } else {
      Logger.d("LogTAG", "request.body() == null");
    }
    //打印url信息
    Logger.w(request.url() + (request.body() != null ? "?" + _parseParams(request.body(), requestBuffer) : ""));
    final Response response = chain.proceed(request);
    return response;
  }
};

代码示例来源：origin: SonarSource/sonarqube

@Test
public void upload() throws IOException {
 ArgumentCaptor<Request> requestCaptor = ArgumentCaptor.forClass(Request.class);
 settings.setProperty(SONAR_TELEMETRY_URL.getKey(), TELEMETRY_URL);
 underTest.start();
 underTest.upload(JSON);
 verify(okHttpClient).newCall(requestCaptor.capture());
 Request request = requestCaptor.getValue();
 assertThat(request.method()).isEqualTo("POST");
 assertThat(request.body().contentType()).isEqualTo(MediaType.parse("application/json; charset=utf-8"));
 Buffer body = new Buffer();
 request.body().writeTo(body);
 assertThat(body.readUtf8()).isEqualTo(JSON);
 assertThat(request.url().toString()).isEqualTo(TELEMETRY_URL);
}

代码示例来源：origin: SonarSource/sonarqube

@Test
 public void opt_out() throws IOException {
  ArgumentCaptor<Request> requestCaptor = ArgumentCaptor.forClass(Request.class);
  settings.setProperty(SONAR_TELEMETRY_URL.getKey(), TELEMETRY_URL);
  underTest.start();

  underTest.optOut(JSON);

  verify(okHttpClient).newCall(requestCaptor.capture());
  Request request = requestCaptor.getValue();
  assertThat(request.method()).isEqualTo("DELETE");
  assertThat(request.body().contentType()).isEqualTo(MediaType.parse("application/json; charset=utf-8"));
  Buffer body = new Buffer();
  request.body().writeTo(body);
  assertThat(body.readUtf8()).isEqualTo(JSON);
  assertThat(request.url().toString()).isEqualTo(TELEMETRY_URL);
 }
}

代码示例来源：origin: web3j/web3j

protected void verifyResult(String expected) throws Exception {
  RequestBody requestBody = requestInterceptor.getRequestBody();
  assertNotNull(requestBody);
  assertThat(requestBody.contentType(), is(HttpService.JSON_MEDIA_TYPE));
  Buffer buffer = new Buffer();
  requestBody.writeTo(buffer);
  assertThat(replaceRequestId(buffer.readUtf8()), is(replaceRequestId(expected)));
}

代码示例来源：origin: square/okhttp

} else {
 Buffer buffer = new Buffer();
 requestBody.writeTo(buffer);

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

/**
 * Converts retrofit request to async-http-client request.
 *
 * @param request retrofit request
 * @return async-http-client request.
 */
@SneakyThrows
protected org.asynchttpclient.Request createRequest(@NonNull Request request) {
 // create async-http-client request builder
 val requestBuilder = new RequestBuilder(request.method());
 // request uri
 requestBuilder.setUrl(request.url().toString());
 // set headers
 val headers = request.headers();
 headers.names().forEach(name -> requestBuilder.setHeader(name, headers.values(name)));
 // set request body
 val body = request.body();
 if (body != null && body.contentLength() > 0) {
  if (body.contentType() != null) {
   requestBuilder.setHeader(HttpHeaderNames.CONTENT_TYPE, body.contentType().toString());
  }
  // write body to buffer
  val okioBuffer = new Buffer();
  body.writeTo(okioBuffer);
  requestBuilder.setBody(okioBuffer.readByteArray());
 }
 // customize the request builder (external customizer can change the request url for example)
 runConsumers(this.requestCustomizers, requestBuilder);
 return requestBuilder.build();
}

代码示例来源：origin: square/okhttp

BufferedSink bufferedRequestBody = Okio.buffer(requestBodyOut);
request.body().writeTo(bufferedRequestBody);
bufferedRequestBody.close();
realChain.eventListener().requestBodyEnd(call, requestBodyOut.successfulCount);

代码示例来源：origin: square/okhttp

byteCount += contentLength;
} else {
 body.writeTo(sink);