override fun contentLength() = -1L

  override fun writeTo(sink: BufferedSink) {
    GzipSink(sink).buffer().use(delegate::writeTo)
  }

  override fun isOneShot() = delegate.isOneShot()

          call.eventListener.followUpDecision(call, response, null)
          return response
        }

        val followUpBody = followUp.body
        if (followUpBody != null && followUpBody.isOneShot()) {
          closeActiveExchange = false
          call.eventListener.followUpDecision(call, response, null)
          return response
        }

        response.body.closeQuietly()

   *  * A retryable server failure (HTTP 503 with a `Retry-After: 0` response header).
   *  * A misdirected request (HTTP 421) on a coalesced connection.
   */
  open fun isOneShot(): Boolean = false

  companion object {
    /** Empty request body with no content-type. */
    @JvmField
    val EMPTY: RequestBody = ByteString.EMPTY.toRequestBody()

    /**

          logger.log("--> END ${request.method} (encoded body omitted)")
        } else if (requestBody.isDuplex()) {
          logger.log("--> END ${request.method} (duplex request body omitted)")
        } else if (requestBody.isOneShot()) {
          logger.log("--> END ${request.method} (one-shot body omitted)")
        } else {
          var buffer = Buffer()
          requestBody.writeTo(buffer)

          var gzippedLength: Long? = null

   *
   *  * If retries are forbidden with [OkHttpClient.retryOnConnectionFailure]. (OkHttp's defaults
   *    permit retries.)
   *  * If OkHttp already attempted to transmit the request body, and [RequestBody.isOneShot] is
   *    true.
   *
   * It won't retry if the exception is a bug or a configuration problem, such as:
   *
   *  * If the remote peer is untrusted: [exception] is an [SSLPeerUnverifiedException].

	public final fun -deprecated_type ()Lokhttp3/MediaType;
	public final fun boundary ()Ljava/lang/String;
	public fun contentLength ()J
	public fun contentType ()Lokhttp3/MediaType;
	public fun isOneShot ()Z
	public final fun part (I)Lokhttp3/MultipartBody$Part;
	public final fun parts ()Ljava/util/List;
	public final fun size ()I
	public final fun type ()Lokhttp3/MediaType;
	public fun writeTo (Lokio/BufferedSink;)V

        override fun contentType(): MediaType? = TODO()

        override fun contentLength(): Long = TODO()

        override fun isDuplex(): Boolean = TODO()

        override fun isOneShot(): Boolean = TODO()

        override fun writeTo(sink: BufferedSink) = TODO()
      }
    requestBody = "".toRequestBody(null)
    requestBody = "".toRequestBody("".toMediaTypeOrNull())

          counter++
          assertThat(counter).isLessThanOrEqualTo(1)
          sink.writeUtf8("Hello request!")
          sink.close()
        }

        override fun isOneShot() = true
      }
    val request =
      request()
        .post(asyncRequestBody)
        .build()
    val response = client.newCall(request).execute()

 *  New: `OkHttpClient.webSocketCloseTimeout` configures how long a web socket connection will wait
    for a graceful shutdown before it performs an abrupt shutdown.

 *  Fix: Honor `RequestBody.isOneShot()` in `MultipartBody`

 *  Fix in `okhttp-coroutines`: Don't leak response bodies in `executeAsync()`. We had a bug where
    we didn't call `Response.close()` if the coroutine was canceled before its response was

	public final fun -deprecated_type ()Lokhttp3/MediaType;
	public final fun boundary ()Ljava/lang/String;
	public fun contentLength ()J
	public fun contentType ()Lokhttp3/MediaType;
	public fun isOneShot ()Z
	public final fun part (I)Lokhttp3/MultipartBody$Part;
	public final fun parts ()Ljava/util/List;
	public final fun size ()I
	public final fun type ()Lokhttp3/MediaType;
	public fun writeTo (Lokio/BufferedSink;)V