set flag ByteArraysPartialInputStream_debug.

sclass Test_ByteArraysPartialInputStream {

  ByteArraysPartialInputStream stream;

  int n = 1000;

  byte[] data;

  void writeInRandomRanges(byte[] data) ctex {

    for (r : splitIntoRandomRangesOfApproximateLength(10, IntRange(0, l(data))))

      stream.write(subByteArray(data, r));

  }

  void writeAndReadInRandomRanges(byte[] data) ctex {

    int n = l(data), iRead = 0;

    for (r : splitIntoRandomRangesOfApproximateLength(10, IntRange(0, n))) {

      stream.write(subByteArray(data, r));

      int readTo = random_incl(iRead, r.end);

      //printVars(+n, +r, +readTo, +iRead);

      for (; iRead < r.end; iRead++)

        assertEquals("Byte " + iRead, ubyteToInt(data[iRead]), stream.read());

      // partially out of data

      if (iRead == r.end)

        assertEquals(-1, stream.read());

    }

    // check reading rest of data

    for (; iRead < n; iRead++)

      assertEquals("Byte " + iRead, ubyteToInt(data[iRead]), stream.read());

  }

  void checkRead(byte[] data) ctex {

    checkReadWithMark(data, -1);

  }

  void checkReadWithMark(byte[] data, int markPos) ctex {

    for i over data: {

      if (i == markPos) stream.mark(n);

      assertEquals("Byte " + i, ubyteToInt(data[i]), stream.read());

    }

    assertEquals(-1, stream.read());

  }

  void test2() ctex {

    stream = new ByteArraysPartialInputStream;

    writeAndReadInRandomRanges(randomBytes(n));

  }

  void test1() ctex {

    stream = new ByteArraysPartialInputStream;

    data = randomBytes(n);

    writeInRandomRanges(data);

    int markPos = random(n);

    checkReadWithMark(data, markPos);

    print("Resetting to " + markPos);

    stream.reset();

    checkRead(subByteArray(data, markPos));

    print("Read OK");

  }

}