}
        }
    }

    protected DefaultRepositorySystemSession initRepoSession() throws Exception {
        DefaultRepositorySystemSession session = new DefaultRepositorySystemSession(h -> false);
        session.setScopeManager(new ScopeManagerImpl(Maven4ScopeManagerConfiguration.INSTANCE));
        session.setArtifactDescriptorPolicy(new SimpleArtifactDescriptorPolicy(true, true));

    JAVA_HOME=`java-config --jre-home`
  fi
fi

if [ -z "$M2_HOME" ] ; then
  ## resolve links - $0 may be a link to maven's home
  PRG="$0"

  # need this for relative symlinks
  while [ -h "$PRG" ] ; do
    ls=`ls -ld "$PRG"`
    link=`expr "$ls" : '.*-> \(.*\)$'`
    if expr "$link" : '/.*' > /dev/null; then
      PRG="$link"
    else
      PRG="`dirname "$PRG"`/$link"
    fi
  done

        // Verify specific bytes
        assertEquals('W', asciiBytes[0]);
        assertEquals('r', asciiBytes[1]);
        assertEquals('L', asciiBytes[2]);
        assertEquals('e', asciiBytes[3]);
        assertEquals('h', asciiBytes[4]);
        assertEquals(0, asciiBytes[5]); // null character
        assertEquals('B', asciiBytes[6]);
        assertEquals('1', asciiBytes[7]);
        assertEquals('3', asciiBytes[8]);

		return int64(n), err
	}

	h := verifier.algorithm.New()
	if _, err = io.Copy(h, io.LimitReader(file, offset)); err != nil {
		return 0, err
	}

	if n, err = io.ReadFull(file, buffer); err != nil {
		return int64(n), err
	}

	if _, err = h.Write(buffer); err != nil {
		return 0, err
	}

	if _, err = io.Copy(h, file); err != nil {
		return 0, err
	}

		setArgs, err := GetAllSets(list.setDriveCount, eps...)
		if err != nil {
			return layout, err
		}

		h := xxhash.New()
		for _, s := range setArgs {
			for _, d := range s {
				h.WriteString(d)
			}
		}

		layout.pools = append(layout.pools, poolDisksLayout{
			cmdline: fmt.Sprintf("hash:%x", h.Sum(nil)),
			layout:  setArgs,
		})
	}
	return layout, err
}

	}

	for i, testCase := range testCases {
		r, err := http.NewRequest(http.MethodGet, "http://localhost/?"+testCase.q, nil)
		if err != nil {
			t.Fatal(err)
		}
		if testCase.h != "" {
			r.Header.Set("x-amz-content-sha256", testCase.h)
		}
		r.ParseForm()
		got := getContentSha256Cksum(r, serviceS3)
		if got != testCase.expected {
			t.Errorf("Test %d: got:%s expected:%s", i+1, got, testCase.expected)
		}
	}

        return "\u03bcs"; // μs
      case MILLISECONDS:
        return "ms";
      case SECONDS:
        return "s";
      case MINUTES:
        return "min";
      case HOURS:
        return "h";
      case DAYS:
        return "d";
    }
    throw new AssertionError();
  }

	}

	if objInfo.IsRemote() {
		gr, err := getTransitionedObjectReader(ctx, bucket, object, rs, h, objInfo, opts)
		if err != nil {
			return nil, err
		}
		unlockOnDefer = false
		return gr.WithCleanupFuncs(nsUnlocker), nil
	}

	fn, off, length, err := NewGetObjectReader(rs, objInfo, opts, h)
	if err != nil {
		return nil, err
	}

	if unlockOnDefer {

              closed.set(true)
              super.close()
            }
          }.buffer()
        }
      }
    val reader = body.charStream()
    assertThat(reader.read()).isEqualTo('h'.code)
    reader.close()
    assertThat(closed.get()).isTrue()
  }

  @Test
  fun sourceSeesBom() {
    val body = "efbbbf68656c6c6f".decodeHex().toResponseBody()
    val source = body.source()

          "ａ=>a", "ｂ=>b","ｃ=>c","ｄ=>d","ｅ=>e","ｆ=>f","ｇ=>g","ｈ=>h","ｉ=>i","ｊ=>j","ｋ=>k","ｌ=>l","ｍ=>m","ｎ=>n","ｏ=>o","ｐ=>p","ｑ=>q","ｒ=>r","ｓ=>s",
          "ｔ=>t","ｕ=>u","ｖ=>v","ｗ=>w","ｘ=>x", "ｙ=>y", "ｚ=>z",
          "Ａ=>A", "Ｂ=>B","Ｃ=>C","Ｄ=>D","Ｅ=>E","Ｆ=>F","Ｇ=>g","Ｈ=>H","Ｉ=>I","Ｊ=>j","Ｋ=>k","Ｌ=>L","Ｍ=>M","Ｎ=>N","Ｏ=>O","Ｐ=>P","Ｑ=>Q","Ｒ=>R","Ｓ=>S",