summaryrefslogtreecommitdiff
path: root/ext/broadcast_channel/01_broadcast_channel.js
diff options
context:
space:
mode:
Diffstat (limited to 'ext/broadcast_channel/01_broadcast_channel.js')
-rw-r--r--ext/broadcast_channel/01_broadcast_channel.js28
1 files changed, 15 insertions, 13 deletions
diff --git a/ext/broadcast_channel/01_broadcast_channel.js b/ext/broadcast_channel/01_broadcast_channel.js
index d365781c1..059f8a4a1 100644
--- a/ext/broadcast_channel/01_broadcast_channel.js
+++ b/ext/broadcast_channel/01_broadcast_channel.js
@@ -3,20 +3,11 @@
/// <reference path="../../core/internal.d.ts" />
import { core, primordials } from "ext:core/mod.js";
-const ops = core.ops;
-import * as webidl from "ext:deno_webidl/00_webidl.js";
-import { createFilteredInspectProxy } from "ext:deno_console/01_console.js";
-import {
- defineEventHandler,
- EventTarget,
- setIsTrusted,
- setTarget,
-} from "ext:deno_web/02_event.js";
-import { defer } from "ext:deno_web/02_timers.js";
-import { DOMException } from "ext:deno_web/01_dom_exception.js";
const {
op_broadcast_recv,
op_broadcast_send,
+ op_broadcast_subscribe,
+ op_broadcast_unsubscribe,
} = core.ensureFastOps();
const {
ArrayPrototypeIndexOf,
@@ -28,6 +19,17 @@ const {
Uint8Array,
} = primordials;
+import * as webidl from "ext:deno_webidl/00_webidl.js";
+import { createFilteredInspectProxy } from "ext:deno_console/01_console.js";
+import {
+ defineEventHandler,
+ EventTarget,
+ setIsTrusted,
+ setTarget,
+} from "ext:deno_web/02_event.js";
+import { defer } from "ext:deno_web/02_timers.js";
+import { DOMException } from "ext:deno_web/01_dom_exception.js";
+
const _name = Symbol("[[name]]");
const _closed = Symbol("[[closed]]");
@@ -95,7 +97,7 @@ class BroadcastChannel extends EventTarget {
if (rid === null) {
// Create the rid immediately, otherwise there is a time window (and a
// race condition) where messages can get lost, because recv() is async.
- rid = ops.op_broadcast_subscribe();
+ rid = op_broadcast_subscribe();
recv();
}
}
@@ -136,7 +138,7 @@ class BroadcastChannel extends EventTarget {
ArrayPrototypeSplice(channels, index, 1);
if (channels.length === 0) {
- ops.op_broadcast_unsubscribe(rid);
+ op_broadcast_unsubscribe(rid);
}
}