maskCursor.close()
      }
    }

    when (opcode) {
      OPCODE_CONTROL_PING -> {
        frameCallback.onReadPing(controlFrameBuffer.readByteString())
      }
      OPCODE_CONTROL_PONG -> {
        frameCallback.onReadPong(controlFrameBuffer.readByteString())
      }
      OPCODE_CONTROL_CLOSE -> {
        var code = CLOSE_NO_STATUS_CODE
        var reason = ""

        if (bodyBuffer.isProbablyUtf8()) {
          append(" \\\n  --data ${bodyBuffer.readUtf8().shellEscape()}")
        } else {
          append(" \\\n  --data-binary ${bodyBuffer.readByteString().hex().shellEscape()}")
        }
      }
    }

  private fun String.shellEscape(): String = "'${replace("'", "'\\''")}'"

        """.trimMargin(),
      )
  }

  private fun bodyToHex(body: RequestBody): String {
    val buffer = Buffer()
    body.writeTo(buffer)
    return buffer.readByteString().hex()
  }

    // The response is not decompressed.
    val response = call.execute()
    assertThat(response.header("Content-Encoding")).isEqualTo("gzip")
    assertThat(response.body.source().readByteString()).isEqualTo(
      gzippedBody.snapshot(),
    )

    // The request did not offer gzip support.
    val recordedRequest = server.takeRequest()