  @Test
  public void lz4AlreadyZippedStream() throws IOException {

    final byte[] bytes =
        StreamUtils.lz4Stream(
            new ByteArrayInputStream(testRecordingZippedBytes),
            DEFAULT_EXPECTED_SIZE,
            CONSUME_TO_BYTES);

    assertArrayEquals(testRecordingZippedBytes, bytes);
  }