diff options
Diffstat (limited to 'ext/node/polyfills')
-rw-r--r-- | ext/node/polyfills/internal/timers.mjs | 30 | ||||
-rw-r--r-- | ext/node/polyfills/timers.ts | 16 |
2 files changed, 41 insertions, 5 deletions
diff --git a/ext/node/polyfills/internal/timers.mjs b/ext/node/polyfills/internal/timers.mjs index 92fb51d57..bdaf95d91 100644 --- a/ext/node/polyfills/internal/timers.mjs +++ b/ext/node/polyfills/internal/timers.mjs @@ -20,6 +20,7 @@ import { ERR_OUT_OF_RANGE } from "ext:deno_node/internal/errors.ts"; import { emitWarning } from "node:process"; import { clearTimeout as clearTimeout_, + setImmediate as setImmediate_, setInterval as setInterval_, setTimeout as setTimeout_, } from "ext:deno_web/02_timers.js"; @@ -115,6 +116,35 @@ Timeout.prototype[Symbol.toPrimitive] = function () { return this[kTimerId]; }; +// Immediate constructor function. +export function Immediate(callback, args) { + this._immediateId = setImmediate_(callback, args); +} + +// Make sure the linked list only shows the minimal necessary information. +Immediate.prototype[inspect.custom] = function (_, options) { + return inspect(this, { + ...options, + // Only inspect one level. + depth: 0, + // It should not recurse. + customInspect: false, + }); +}; + +// FIXME(nathanwhit): actually implement {ref,unref,hasRef} once deno_core supports it +Immediate.prototype.unref = function () { + return this; +}; + +Immediate.prototype.ref = function () { + return this; +}; + +Immediate.prototype.hasRef = function () { + return true; +}; + /** * @param {number} msecs * @param {string} name diff --git a/ext/node/polyfills/timers.ts b/ext/node/polyfills/timers.ts index 9a7d59ab2..033afd952 100644 --- a/ext/node/polyfills/timers.ts +++ b/ext/node/polyfills/timers.ts @@ -11,6 +11,7 @@ const { import { activeTimers, + Immediate, setUnrefTimeout, Timeout, } from "ext:deno_node/internal/timers.mjs"; @@ -21,7 +22,6 @@ import * as timers from "ext:deno_web/02_timers.js"; const clearTimeout_ = timers.clearTimeout; const clearInterval_ = timers.clearInterval; -const setImmediate_ = timers.setImmediate; export function setTimeout( callback: (...args: unknown[]) => void, @@ -70,15 +70,21 @@ export function clearInterval(timeout?: Timeout | number | string) { } clearInterval_(id); } -// TODO(bartlomieju): implement the 'NodeJS.Immediate' versions of the timers. -// https://github.com/DefinitelyTyped/DefinitelyTyped/blob/1163ead296d84e7a3c80d71e7c81ecbd1a130e9a/types/node/v12/globals.d.ts#L1120-L1131 export function setImmediate( cb: (...args: unknown[]) => void, ...args: unknown[] ): Timeout { - return setImmediate_(cb, ...args); + return new Immediate(cb, ...args); +} +export function clearImmediate(immediate: Immediate) { + if (immediate == null) { + return; + } + + // FIXME(nathanwhit): will probably change once + // deno_core has proper support for immediates + clearTimeout_(immediate._immediateId); } -export const clearImmediate = clearTimeout; export default { setTimeout, |