forked from nodejs/node
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
timers: move promisified timers implementations
Move the promisified timers implementations into a new internal. submodule. Also adds `ref` option to the promisified versions. Signed-off-by: James M Snell <jasnell@gmail.com> PR-URL: nodejs#33950 Reviewed-By: Denys Otrishko <shishugi@gmail.com> Reviewed-By: Benjamin Gruenbaum <benjamingr@gmail.com>
- Loading branch information
Showing
5 changed files
with
194 additions
and
128 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,124 @@ | ||
| 'use strict'; | ||
|
|
||
| const { | ||
| Promise, | ||
| PromiseReject, | ||
| } = primordials; | ||
|
|
||
| const { | ||
| Timeout, | ||
| Immediate, | ||
| insert | ||
| } = require('internal/timers'); | ||
|
|
||
| const { | ||
| hideStackFrames, | ||
| codes: { ERR_INVALID_ARG_TYPE } | ||
| } = require('internal/errors'); | ||
|
|
||
| let DOMException; | ||
|
|
||
| const lazyDOMException = hideStackFrames((message) => { | ||
| if (DOMException === undefined) | ||
| DOMException = internalBinding('messaging').DOMException; | ||
| return new DOMException(message); | ||
| }); | ||
|
|
||
| function setTimeout(after, value, options = {}) { | ||
| const args = value !== undefined ? [value] : value; | ||
| if (options == null || typeof options !== 'object') { | ||
| return PromiseReject( | ||
| new ERR_INVALID_ARG_TYPE( | ||
| 'options', | ||
| 'Object', | ||
| options)); | ||
| } | ||
| const { signal, ref = true } = options; | ||
| if (signal !== undefined && | ||
| (signal === null || | ||
| typeof signal !== 'object' || | ||
| !('aborted' in signal))) { | ||
| return PromiseReject( | ||
| new ERR_INVALID_ARG_TYPE( | ||
| 'options.signal', | ||
| 'AbortSignal', | ||
| signal)); | ||
| } | ||
| if (typeof ref !== 'boolean') { | ||
| return PromiseReject( | ||
| new ERR_INVALID_ARG_TYPE( | ||
| 'options.ref', | ||
| 'boolean', | ||
| ref)); | ||
| } | ||
| // TODO(@jasnell): If a decision is made that this cannot be backported | ||
| // to 12.x, then this can be converted to use optional chaining to | ||
| // simplify the check. | ||
| if (signal && signal.aborted) | ||
| return PromiseReject(lazyDOMException('AbortError')); | ||
| return new Promise((resolve, reject) => { | ||
| const timeout = new Timeout(resolve, after, args, false, true); | ||
| if (!ref) timeout.unref(); | ||
| insert(timeout, timeout._idleTimeout); | ||
| if (signal) { | ||
| signal.addEventListener('abort', () => { | ||
| if (!timeout._destroyed) { | ||
| // eslint-disable-next-line no-undef | ||
| clearTimeout(timeout); | ||
| reject(lazyDOMException('AbortError')); | ||
| } | ||
| }, { once: true }); | ||
| } | ||
| }); | ||
| } | ||
|
|
||
| function setImmediate(value, options = {}) { | ||
| if (options == null || typeof options !== 'object') { | ||
| return PromiseReject( | ||
| new ERR_INVALID_ARG_TYPE( | ||
| 'options', | ||
| 'Object', | ||
| options)); | ||
| } | ||
| const { signal, ref = true } = options; | ||
| if (signal !== undefined && | ||
| (signal === null || | ||
| typeof signal !== 'object' || | ||
| !('aborted' in signal))) { | ||
| return PromiseReject( | ||
| new ERR_INVALID_ARG_TYPE( | ||
| 'options.signal', | ||
| 'AbortSignal', | ||
| signal)); | ||
| } | ||
| if (typeof ref !== 'boolean') { | ||
| return PromiseReject( | ||
| new ERR_INVALID_ARG_TYPE( | ||
| 'options.ref', | ||
| 'boolean', | ||
| ref)); | ||
| } | ||
| // TODO(@jasnell): If a decision is made that this cannot be backported | ||
| // to 12.x, then this can be converted to use optional chaining to | ||
| // simplify the check. | ||
| if (signal && signal.aborted) | ||
| return PromiseReject(lazyDOMException('AbortError')); | ||
| return new Promise((resolve, reject) => { | ||
| const immediate = new Immediate(resolve, [value]); | ||
| if (!ref) immediate.unref(); | ||
| if (signal) { | ||
| signal.addEventListener('abort', () => { | ||
| if (!immediate._destroyed) { | ||
| // eslint-disable-next-line no-undef | ||
| clearImmediate(immediate); | ||
| reject(lazyDOMException('AbortError')); | ||
| } | ||
| }, { once: true }); | ||
| } | ||
| }); | ||
| } | ||
|
|
||
| module.exports = { | ||
| setTimeout, | ||
| setImmediate, | ||
| }; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.