Method testEagerStream

java/org/brotli/dec/EagerStreamTest.java:367–385

()

  }

  @Test
  public void testEagerStream() throws IOException {
    ProxyStream ps = new ProxyStream(new ByteArrayInputStream(DATA));
    BrotliInputStream reader = new BrotliInputStream(ps, 1);
    byte[] buffer = new byte[1];
    reader.read(buffer);
    reader.close();
    int normalReadBytes = ps.readBytes;

    ps = new ProxyStream(new ByteArrayInputStream(DATA));
    reader = new BrotliInputStream(ps, 1);
    reader.enableEagerOutput();
    reader.read(buffer);
    reader.close();
    int eagerReadBytes = ps.readBytes;

    // Did not continue decoding - suspended as soon as enough data was decoded.
    assertTrue(eagerReadBytes < normalReadBytes);
  }
}