isUpgradeRequest && isUpgradeResponse -> {
            response
              .newBuilder()
              .body(
                UnreadableResponseBody(
                  response.body.contentType(),
                  response.body.contentLength(),
                ),
              ).socket(exchange.upgradeToSocket())
              .build()
          }

          // This is not an upgrade response.

   * is not available, and it is always an error to attempt read its streamed content. Reading from
   * [ResponseBody.source] always throws on such instances.
   *
   * It is safe and supported to call [ResponseBody.contentType] and [ResponseBody.contentLength] on
   * all instances of [ResponseBody].
   */
  @get:JvmName("body") val body: ResponseBody,
  /**
   * Non-null if this response is a successful upgrade ...
   */

		return
	}

	// Ensure body content type is opaque to ensure that request body has not
	// been interpreted as form data.
	contentType := r.Header.Get("Content-Type")
	if contentType != "application/octet-stream" {
		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrBadRequest), r.URL)
		return
	}

	operation := mux.Vars(r)["operation"]

    @Test
    public void test_setContentType() {
        final OsddHelper osddHelper = new OsddHelper();
        osddHelper.setContentType("application/xml");
        assertEquals("application/xml", osddHelper.contentType);
    }

    @Test
    public void test_isOsddLinkEnabled_blank_ssoType() {
        ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {
            @Override

    private var currentPart: PartSource? = null

    @Throws(IOException::class)
    constructor(response: ResponseBody) : this(
      source = response.source(),
      boundary =
        response.contentType()?.parameter("boundary")
          ?: throw ProtocolException("expected the Content-Type to have a boundary parameter"),
    )

    @Throws(IOException::class)
    fun nextPart(): Part? {

    assertThat(body.value(0)).isEqualTo("c+=& d")
    assertThat(body.value(1)).isEqualTo("final frontier")
    assertThat(body.value(2)).isEqualTo("%25")
    assertThat(body.contentType().toString()).isEqualTo(
      "application/x-www-form-urlencoded",
    )
    val expected = "a%2B%3D%26+b=c%2B%3D%26+d&space%2C+the=final+frontier&%2525=%2525"

		return
	}

	if _, _, err := globalBucketMetadataSys.GetReplicationConfig(ctx, bucket); err != nil {
		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
		return
	}

	w.Header().Set(xhttp.ContentType, string(mimeJSON))

	enc := json.NewEncoder(w)
	stats := globalReplicationStats.Load().getLatestReplicationStats(bucket)
	bwRpt := globalNotificationSys.GetBandwidthReports(ctx, bucket)
	bwMap := bwRpt.BucketStats

HSPLokhttp3/internal/_RequestBodyCommonKt$commonToRequestBody$1;-><init>(Lokhttp3/MediaType;I[BI)V
HSPLokhttp3/internal/_RequestBodyCommonKt$commonToRequestBody$1;->contentLength()J
HSPLokhttp3/internal/_RequestBodyCommonKt$commonToRequestBody$1;->contentType()Lokhttp3/MediaType;
HSPLokhttp3/internal/_RequestBodyCommonKt$commonToRequestBody$1;->writeTo(Lokio/BufferedSink;)V

	//	 Date/Expires + "\n" +
	//	 CanonicalizedProtocolHeaders +
	//	 CanonicalizedResource;
	stringToSign := strings.Join([]string{
		method,
		headers.Get(xhttp.ContentMD5),
		headers.Get(xhttp.ContentType),
		date,
		canonicalHeaders,
	}, "\n")

	return stringToSign + canonicalizedResourceV2(encodedResource, encodedQuery)

	if err != nil {
		t.Fatalf("%s: <ERROR> %s", instanceType, err)
	}

	if objInfo.ContentType != "image/png" {
		t.Errorf("%s: Expected Content type to be `%s`, but instead found `%s`", instanceType, "image/png", objInfo.ContentType)
	}