1 files changed, 8 insertions, 2 deletions
diff --git a/ext/web/14_compression.js b/ext/web/14_compression.js
index 1ec9e5462..0d3a8ebd0 100644
--- a/ext/web/14_compression.js
+++ b/ext/web/14_compression.js
@@ -50,9 +50,12 @@ class CompressionStream {
         maybeEnqueue(controller, output);
       },
       flush(controller) {
-        const output = op_compression_finish(rid);
+        const output = op_compression_finish(rid, true);
         maybeEnqueue(controller, output);
       },
+      cancel: (_reason) => {
+        op_compression_finish(rid, false);
+      },
     });
 
     this[webidl.brand] = webidl.brand;
@@ -109,9 +112,12 @@ class DecompressionStream {
         maybeEnqueue(controller, output);
       },
       flush(controller) {
-        const output = op_compression_finish(rid);
+        const output = op_compression_finish(rid, true);
         maybeEnqueue(controller, output);
       },
+      cancel: (_reason) => {
+        op_compression_finish(rid, false);
+      },
     });
 
     this[webidl.brand] = webidl.brand;