refactor: Remove delete legacy Stream versions

Author: ryanhallock

src/main/java/dev/hallock/zstd/ZstdCompressionContext.java

@@ -12,6 +12,7 @@ public ZstdCompressionContext() {
         this.cctx = ZSTD_h.ZSTD_createCCtx();
     }
 
+    /// @apiNote Uses compress2
     public ZstdResult compress(MemorySegment dst, long dstCapacity, MemorySegment src, long srcSize) {
         Objects.requireNonNull(dst, "dst");
         if (dstCapacity > dst.byteSize())
@@ -22,6 +23,7 @@ public ZstdResult compress(MemorySegment dst, long dstCapacity, MemorySegment sr
         return ZstdResult.from(ZSTD_h.ZSTD_compress2(this.cctx, dst, dstCapacity, src, srcSize));
     }
 
+    /// @apiNote Uses compressStream2
     public ZstdResult compressStream(ZstdOutputBuffer output, ZstdInputBuffer input, ZstdEndDirective endDirective) {
         Objects.requireNonNull(output, "output");
         Objects.requireNonNull(input, "input");

src/main/java/dev/hallock/zstd/ZstdCompressionStream.java

@@ -48,6 +48,12 @@ public ZstdResult parameter(ZstdDecompressionParameter parameter, int value) {
         return ZstdResult.from(ZSTD_h.ZSTD_DCtx_setParameter(this.dctx, parameter.value(), value));
     }
 
+    public ZstdResult decompressStream(ZstdOutputBuffer outBuf, ZstdInputBuffer inBuf) {
+        Objects.requireNonNull(outBuf, "outBuf");
+        Objects.requireNonNull(inBuf, "inBuf");
+        return ZstdResult.from(ZSTD_h.ZSTD_decompressStream(this.dctx, outBuf.output(), inBuf.input()));
+    }
+
     @Override
     public void close() throws ZstdException {
         ZstdResult.check(ZSTD_h.ZSTD_freeDCtx(this.dctx));

src/main/java/dev/hallock/zstd/ZstdDecompressionContext.java

@@ -45,7 +45,8 @@ void testOutputBufferOperations() {
     @Test
     void testInputBufferInStream() throws Exception {
         try (Arena arena = Arena.ofConfined();
-             ZstdCompressionStream stream = new ZstdCompressionStream(Zstd.defaultCompressionLevel())) {
+            ZstdCompressionContext stream = new ZstdCompressionContext()) {
+            stream.parameter(ZstdCompressionParameter.COMPRESSION_LEVEL, Zstd.defaultCompressionLevel());
 
             MemorySegment input = arena.allocate(1000);
             MemorySegment output = arena.allocate(2000);
@@ -57,7 +58,7 @@ void testInputBufferInStream() throws Exception {
             inBuf.position(0);
             outBuf.position(0);
 
-            stream.compressionStream(outBuf, inBuf);
+            stream.compressStream(outBuf, inBuf, ZstdEndDirective.END);
 
             assertTrue(inBuf.position() >= 0);
             assertTrue(outBuf.position() >= 0);
@@ -67,7 +68,7 @@ void testInputBufferInStream() throws Exception {
     @Test
     void testOutputBufferInStream() throws Exception {
         try (Arena arena = Arena.ofConfined();
-             ZstdDecompressionStream stream = new ZstdDecompressionStream()) {
+             ZstdDecompressionContext stream = new ZstdDecompressionContext()) {
 
             byte[] compressedData = compressTestData();
             MemorySegment input = arena.allocate(compressedData.length);
@@ -82,7 +83,7 @@ void testOutputBufferInStream() throws Exception {
             outBuf.position(0);
             outBuf.size(1000);
 
-            stream.decompressStream(outBuf, inBuf);
+            assertInstanceOf(ZstdResult.Ok.class, stream.decompressStream(outBuf, inBuf));
 
             assertTrue(outBuf.position() > 0);
         }