flush after each push in fflate deflate data processor

aternosorg · Apr 10, 2024 · 8e3bcb1 · 8e3bcb1
1 parent d8f64a7
commit 8e3bcb1
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 5 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "armarius-io",
-  "version": "1.2.0",
+  "version": "1.2.1",
   "description": "IO and compression library for Armarius",
   "repository": "github:aternosorg/armarius-io",
   "type": "module",

diff --git a/src/DataProcessor/Native/NativeDeflateDataProcessor.js b/src/DataProcessor/Native/NativeDeflateDataProcessor.js
@@ -8,4 +8,13 @@ export default class NativeDeflateDataProcessor extends NativeStreamDataProcesso
         // noinspection JSUnresolvedFunction
         return new CompressionStream('deflate-raw');
     }
+
+    /**
+     * @inheritDoc
+     */
+    push(data, final) {
+        if (!final) {
+            this.flate.flush();
+        }
+    }
 }