assertEquals(bytes.length, source.copyTo(sink));
    assertTrue(source.wasStreamOpened() && source.wasStreamClosed());
    assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed());

    assertArrayEquals(bytes, sink.getBytes());
  }

  public void testRead_toArray() throws IOException {
    assertArrayEquals(bytes, source.read());
    assertTrue(source.wasStreamOpened() && source.wasStreamClosed());
  }

        // Upload file
        Response response = given().header("Authorization", getTestToken())
                .multiPart("file", NAME_PREFIX + "test.txt", fileContent.getBytes())
                .when()
                .put(getApiPath() + "/upload/");

        // Storage may not be enabled, so accept various responses
        int statusCode = response.getStatusCode();

    DataInput in = new DataInputStream(new ByteArrayInputStream(data));

    /* Read in various values NORMALLY */
    byte[] b = new byte[6];
    in.readFully(b);
    assertEquals("r\u00C9sum\u00C9".getBytes(ISO_8859_1), b);
  }

  @SuppressWarnings("deprecation") // testing a deprecated method
  public void testWriteBytes_discardHighOrderBytes() throws IOException {

    DataInput in = new DataInputStream(new ByteArrayInputStream(data));

    /* Read in various values NORMALLY */
    byte[] b = new byte[6];
    in.readFully(b);
    assertEquals("r\u00C9sum\u00C9".getBytes(ISO_8859_1), b);
  }

  @SuppressWarnings("deprecation") // testing a deprecated method
  public void testWriteBytes_discardHighOrderBytes() throws IOException {

        int state, t, x, i, off;
        byte ch;
        final byte[] type = new byte[128];
        final byte[] buf = new byte[16];
        final byte[] ext = extension.toLowerCase().getBytes("ASCII");

        state = ST_START;
        t = x = i = 0;
        for (off = 0; off < inLen; off++) {
            ch = in[off];
            switch (state) {
            case ST_START:

     *
     * @return the byte array if operation succeeded, {@code null} if source does not exist.
     * @throws RuntimeException If failed (and not due source not exists).
     */
    @Nonnull
    Optional<byte[]> getBytes(@Nonnull URI relativeSource);

    /**
     * GETs the source URI content as string. The source MUST BE relative from the {@link RemoteRepository#getUrl()}
     * root.
     *

      random.nextBytes(bytes);
      String s = new String(bytes, UTF_16LE); // so all random strings are valid
      assertEquals(
          new Sink(4).putUnencodedChars(s).hash(),
          new Sink(4).putBytes(s.getBytes(UTF_16LE)).hash());
      assertEquals(
          new Sink(4).putUnencodedChars(s).hash(), new Sink(4).putString(s, UTF_16LE).hash());
    }
  }

  public void testFloat() {
    Sink sink = new Sink(4);

                    break;
                case 1:
                    final ASN1BitString ctxFlags = ASN1BitString.getInstance(tagged, true);
                    setContextFlags(ctxFlags.getBytes()[0] & 0xff);
                    break;
                case 2:
                    final ASN1OctetString mechanismToken = ASN1OctetString.getInstance(tagged, true);

            final String value = username + ":" + password;
            final String basicAuth = "Basic " + java.util.Base64.getEncoder().encodeToString(value.getBytes(StandardCharsets.UTF_8));
            request.header("Authorization", basicAuth);
        }
        if (sslSocketFactory != null) {
            request.sslSocketFactory(sslSocketFactory);
        }

 * it returns a ByteArrayInputStream.
 *
 * <p>Example usage:
 * <pre>
 * {@code
 * // In-memory caching
 * byte[] data = "example data".getBytes();
 * try (ContentCache cache = new ContentCache(data)) {
 *     InputStream inputStream = cache.getInputStream();
 *     // Read from inputStream
 * }
 *
 * // File-based caching