add comments

avast · Dec 20, 2023 · 2cc74ee · 2cc74ee
1 parent f736bcc
commit 2cc74ee
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/core/src/main/scala/com/avast/clients/storage/compression/ZstdDecompressOutputStream.scala b/core/src/main/scala/com/avast/clients/storage/compression/ZstdDecompressOutputStream.scala
@@ -18,7 +18,7 @@ class ZstdDecompressOutputStream(outputStream: OutputStream) extends OutputStrea
       throw new IllegalStateException("Stream is closed")
     }
 
-    val inputBuffer = ByteBuffer.allocateDirect(chunk.length)
+    val inputBuffer = ByteBuffer.allocateDirect(chunk.length) // ByteBuffer.wrap(chunk) does not work, we need direct buffer
     inputBuffer.put(chunk)
     inputBuffer.rewind()
 

diff --git a/...src/test/scala/com/avast/clients/storage/compression/ZstdDecompressOutputStreamTest.scala b/...src/test/scala/com/avast/clients/storage/compression/ZstdDecompressOutputStreamTest.scala
@@ -17,7 +17,7 @@ class ZstdDecompressOutputStreamTest extends FunSuite {
   }
 
   private def generateData(size: Int): Array[Byte] = {
-    1.to(size).map(i => (i % 256).toByte).toArray
+    1.to(size).map(i => (i % 256).toByte).toArray // generates compressible data, random data wouldn't compress well
   }
 
   test("decompress zstd stream") {