diff options
Diffstat (limited to 'ext/broadcast_channel/01_broadcast_channel.js')
-rw-r--r-- | ext/broadcast_channel/01_broadcast_channel.js | 28 |
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); } } |