s3.getObject({Bucket: 'your-bucket', Key: 'path/to/file.zip/data.csv'}).
    on('build', function(req) { req.httpRequest.headers['X-Minio-Extract'] = 'true'; }).
    on('httpData', function(chunk) { file.write(chunk); }).
    on('httpDone', function() { file.end(); }).

		"${MINIO[@]}" --address ":$((start_port + i))" ${args[@]} 2>&1 >"${WORK_DIR}/server$i.log" &
	done

	# Wait until all nodes return 403
	for i in $(seq 1 4); do
		while [ "$(curl -m 1 -s -o /dev/null -w "%{http_code}" http://localhost:$((start_port + i)))" -ne "403" ]; do
			echo -n "."
			sleep 1
		done
	done

}

# Prepare fake disks with losetup
function prepare_block_devices() {
	set -e

    writeMedium(frame, 4)
    frame.writeByte(Http2.TYPE_RST_STREAM)
    frame.writeByte(FLAG_NONE)
    frame.writeInt(expectedStreamId and 0x7fffffff)
    frame.writeInt(ErrorCode.PROTOCOL_ERROR.httpCode)
    reader.nextFrame(
      requireSettings = false,
      object : BaseTestHandler() {
        override fun rstStream(
          streamId: Int,
          errorCode: ErrorCode,
        ) {

  val ipv6 = InetAddress.getByName("2001:db8:ffff:ffff:ffff:ffff:ffff:1")

  val refusedStream =
    MockResponse
      .Builder()
      .onRequestStart(CloseStream(ErrorCode.REFUSED_STREAM.httpCode))
      .build()
  val bodyResponse = MockResponse(body = "body")

  @BeforeEach
  fun setUp() {
    socketFactory = SpecificHostSocketFactory(InetSocketAddress(server1.hostName, server1.port))

    client =

          },
        ).build()

    // Set up a same-connection retry.
    serverIpv4.enqueue(
      MockResponse
        .Builder()
        .onRequestStart(CloseStream(ErrorCode.REFUSED_STREAM.httpCode))
        .build(),
    )
    serverIpv4.enqueue(
      MockResponse(body = "this was the 2nd request on IPv4"),
    )
    serverIpv6.enqueue(
      MockResponse(body = "unexpected call to IPv6"),
    )

     */
    public fun doNotReadRequestBody(): Builder =
      apply {
        doNotReadRequestBody = true
        onResponseEnd = CloseStream(ErrorCode.NO_ERROR.httpCode)
      }

    /** Trigger [socketEffect] while reading the request body. */
    public fun onRequestBody(socketEffect: SocketEffect?): Builder =
      apply {
        this.onRequestBody = socketEffect
      }

				"application/vnd.hp-hpgl",
				"application/vnd.hp-hpid",
				"application/vnd.hp-hps",
				"application/vnd.hp-jlyt",
				"application/vnd.hp-pcl",
				"application/vnd.hp-pclxl",
				"application/vnd.httphone",
				"application/vnd.hydrostatix.sof-data",
				"application/vnd.hzn-3d-crossword",
				"application/vnd.ibm.afplinedata",
				"application/vnd.ibm.electronic-media",
				"application/vnd.ibm.minipay",

    <glob pattern="*.pcl"/>
  </mime-type>
  <mime-type type="application/vnd.hp-pclxl">
    <glob pattern="*.pclxl"/>
  </mime-type>
  <mime-type type="application/vnd.httphone"/>
  <mime-type type="application/vnd.hydrostatix.sof-data">
    <glob pattern="*.sfd-hdstx"/>
  </mime-type>
  <mime-type type="application/vnd.hzn-3d-crossword">
    <glob pattern="*.x3d"/>
  </mime-type>