diff options
Diffstat (limited to 'ext')
-rw-r--r-- | ext/node/polyfills/async_hooks.ts | 11 | ||||
-rw-r--r-- | ext/web/13_message_port.js | 36 |
2 files changed, 25 insertions, 22 deletions
diff --git a/ext/node/polyfills/async_hooks.ts b/ext/node/polyfills/async_hooks.ts index 9240d56c5..f2733e92d 100644 --- a/ext/node/polyfills/async_hooks.ts +++ b/ext/node/polyfills/async_hooks.ts @@ -7,11 +7,12 @@ // TODO(petamoriken): enable prefer-primordials for node polyfills // deno-lint-ignore-file prefer-primordials +import { core } from "ext:core/mod.js"; +const { + op_node_is_promise_rejected, +} = core.ensureFastOps(); import { validateFunction } from "ext:deno_node/internal/validators.mjs"; -const { core } = globalThis.__bootstrap; -const { ops } = core; - function assert(cond: boolean) { if (!cond) throw new Error("Assertion failed"); } @@ -57,7 +58,7 @@ function setPromiseHooks() { }; const after = (promise: Promise<unknown>) => { popAsyncFrame(); - if (!ops.op_node_is_promise_rejected(promise)) { + if (!op_node_is_promise_rejected(promise)) { // @ts-ignore promise async context promise[asyncContext] = undefined; } @@ -65,7 +66,7 @@ function setPromiseHooks() { const resolve = (promise: Promise<unknown>) => { const currentFrame = AsyncContextFrame.current(); if ( - !currentFrame.isRoot() && ops.op_node_is_promise_rejected(promise) && + !currentFrame.isRoot() && op_node_is_promise_rejected(promise) && typeof promise[asyncContext] === "undefined" ) { AsyncContextFrame.attachContext(promise); diff --git a/ext/web/13_message_port.js b/ext/web/13_message_port.js index 0fddfc2e8..e4df3afcb 100644 --- a/ext/web/13_message_port.js +++ b/ext/web/13_message_port.js @@ -7,18 +7,11 @@ /// <reference path="./lib.deno_web.d.ts" /> import { core, primordials } from "ext:core/mod.js"; -const { InterruptedPrototype, ops } = core; -import * as webidl from "ext:deno_webidl/00_webidl.js"; -import { createFilteredInspectProxy } from "ext:deno_console/01_console.js"; -import { - defineEventHandler, - EventTarget, - MessageEvent, - setEventTargetData, - setIsTrusted, -} from "ext:deno_web/02_event.js"; -import { isDetachedBuffer } from "ext:deno_web/06_streams.js"; -import { DOMException } from "ext:deno_web/01_dom_exception.js"; +const { + op_message_port_post_message, + op_message_port_recv_message, + op_message_port_create_entangled, +} = core.ensureFastOps(); const { ArrayBufferPrototypeGetByteLength, ArrayPrototypeFilter, @@ -31,11 +24,20 @@ const { TypeError, } = primordials; const { + InterruptedPrototype, isArrayBuffer, } = core; -const { - op_message_port_recv_message, -} = core.ensureFastOps(); +import * as webidl from "ext:deno_webidl/00_webidl.js"; +import { createFilteredInspectProxy } from "ext:deno_console/01_console.js"; +import { + defineEventHandler, + EventTarget, + MessageEvent, + setEventTargetData, + setIsTrusted, +} from "ext:deno_web/02_event.js"; +import { isDetachedBuffer } from "ext:deno_web/06_streams.js"; +import { DOMException } from "ext:deno_web/01_dom_exception.js"; class MessageChannel { /** @type {MessagePort} */ @@ -140,7 +142,7 @@ class MessagePort extends EventTarget { } const data = serializeJsMessageData(message, transfer); if (this[_id] === null) return; - ops.op_message_port_post_message(this[_id], data); + op_message_port_post_message(this[_id], data); } start() { @@ -220,7 +222,7 @@ const MessagePortPrototype = MessagePort.prototype; * @returns {[number, number]} */ function opCreateEntangledMessagePort() { - return ops.op_message_port_create_entangled(); + return op_message_port_create_entangled(); } /** |