add it to the correct class so it actually does something

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

Hide file tree

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

diff --git a/src/DataProcessor/Fflate/FflateDeflateDataProcessor.js b/src/DataProcessor/Fflate/FflateDeflateDataProcessor.js
@@ -9,5 +9,15 @@ export default class FflateDeflateDataProcessor extends FflateDataProcessor {
         this.flate = new Deflate();
         this.flate.ondata = this.onData.bind(this);
     }
+
+    /**
+     * @inheritDoc
+     */
+    push(data, final) {
+        super.push(data, final);
+        if (!final) {
+            this.flate.flush();
+        }
+    }
 }
 
diff --git a/src/DataProcessor/Native/NativeDeflateDataProcessor.js b/src/DataProcessor/Native/NativeDeflateDataProcessor.js
@@ -8,13 +8,4 @@ export default class NativeDeflateDataProcessor extends NativeStreamDataProcesso
         // noinspection JSUnresolvedFunction
         return new CompressionStream('deflate-raw');
     }
-
-    /**
-     * @inheritDoc
-     */
-    push(data, final) {
-        if (!final) {
-            this.flate.flush();
-        }
-    }
 }