summaryrefslogtreecommitdiff
path: root/ext/web/14_compression.js
diff options
context:
space:
mode:
authorKenta Moriuchi <moriken@kimamass.com>2024-01-11 07:37:25 +0900
committerGitHub <noreply@github.com>2024-01-10 15:37:25 -0700
commit515a34b4de222e35c7ade1b92614d746e73d4c2e (patch)
tree8284201fc826a33f12597959a8a8be14e0f524bd /ext/web/14_compression.js
parentd4893eb51a01c5a692d8ca74a3b8ff95c5fd1d9f (diff)
refactor: use `core.ensureFastOps()` (#21888)
Diffstat (limited to 'ext/web/14_compression.js')
-rw-r--r--ext/web/14_compression.js19
1 files changed, 12 insertions, 7 deletions
diff --git a/ext/web/14_compression.js b/ext/web/14_compression.js
index bc16f0448..411fa8c84 100644
--- a/ext/web/14_compression.js
+++ b/ext/web/14_compression.js
@@ -6,12 +6,17 @@
/// <reference path="./lib.deno_web.d.ts" />
import { core, primordials } from "ext:core/mod.js";
-const ops = core.ops;
+const {
+ op_compression_finish,
+ op_compression_new,
+ op_compression_write,
+} = core.ensureFastOps();
const {
SymbolFor,
ObjectPrototypeIsPrototypeOf,
TypedArrayPrototypeGetByteLength,
} = primordials;
+
import * as webidl from "ext:deno_webidl/00_webidl.js";
import { createFilteredInspectProxy } from "ext:deno_console/01_console.js";
import { TransformStream } from "ext:deno_web/06_streams.js";
@@ -33,19 +38,19 @@ class CompressionStream {
webidl.requiredArguments(arguments.length, 1, prefix);
format = webidl.converters.CompressionFormat(format, prefix, "Argument 1");
- const rid = ops.op_compression_new(format, false);
+ const rid = op_compression_new(format, false);
this.#transform = new TransformStream({
transform(chunk, controller) {
chunk = webidl.converters.BufferSource(chunk, prefix, "chunk");
- const output = ops.op_compression_write(
+ const output = op_compression_write(
rid,
chunk,
);
maybeEnqueue(controller, output);
},
flush(controller) {
- const output = ops.op_compression_finish(rid);
+ const output = op_compression_finish(rid);
maybeEnqueue(controller, output);
},
});
@@ -92,19 +97,19 @@ class DecompressionStream {
webidl.requiredArguments(arguments.length, 1, prefix);
format = webidl.converters.CompressionFormat(format, prefix, "Argument 1");
- const rid = ops.op_compression_new(format, true);
+ const rid = op_compression_new(format, true);
this.#transform = new TransformStream({
transform(chunk, controller) {
chunk = webidl.converters.BufferSource(chunk, prefix, "chunk");
- const output = ops.op_compression_write(
+ const output = op_compression_write(
rid,
chunk,
);
maybeEnqueue(controller, output);
},
flush(controller) {
- const output = ops.op_compression_finish(rid);
+ const output = op_compression_finish(rid);
maybeEnqueue(controller, output);
},
});