Сжатие InputStream с помощью GZIPOutputStream в ByteArray

Question

У меня есть метод, который принимает InputStream в качестве параметра, и я пытаюсь сжать входной поток с помощью GZIPOutputStream, а затем вернуть сжатый байтовый массив. Мой код выглядит так:

    public static byte[] compress(final InputStream inputStream) throws IOException {
    final int byteArrayOutputStreamSize = Math.max(32, inputStream.available());
    try(final ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(byteArrayOutputStreamSize);
    final GZIPOutputStream gzipOutputStream = new GZIPOutputStream(byteArrayOutputStream)) {
        IOUtils.copy(inputStream, gzipOutputStream);
        return byteArrayOutputStream.toByteArray();
    }
}

Но почему-то это не работает. Я пытаюсь выполнить модульное тестирование с помощью следующего кода:

    @Test
public void testCompress() throws Exception {
    final String uncompressedBytes = "some text here".getBytes();
    final InputStream inputStream = ByteSource.wrap(uncompressedBytes).openStream();
    final byte[] compressedBytes = CompressionHelper.compress(inputStream);
    Assert.assertNotNull(compressedBytes);
    final byte[] decompressedBytes = decompress(compressedBytes);
    Assert.assertEquals(uncompressedBytes, decompressedBytes);
}

public static byte[] decompress(byte[] contentBytes) throws Exception {
    try (ByteArrayOutputStream out = new ByteArrayOutputStream();
         ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(contentBytes);
         InputStream inputStream = new GZIPInputStream(byteArrayInputStream)) {
        IOUtils.copy(inputStream, out);
        return out.toByteArray();
    }
}

Но я получаю это исключение

java.io.EOFException: неожиданный конец входного потока ZLIB

Что я делаю не так?

Answer 1

Очистка и закрытие выходного потока после копирования входного потока в выходной поток устранила проблему:

         IOUtils.copy(inputStream, gzipOutputStream);
         gzipOutputStream.flush();
         gzipOutputStream.close();