Implemented await delay(msec, signal)

PR-URL: #31

CHANGELOG.md

@@ -2,6 +2,7 @@
 
 ## [Unreleased][unreleased]
 
+- Implemented `await delay(msec, signal)`
 - Fix timeout behaviour to reject promise (throw)
 - Generate errors on timeout and on abort timeout
 

lib/utilities.js

@@ -162,6 +162,16 @@ const timeout = (msec, signal = null) =>
     });
   });
 
+const delay = (msec, signal = null) =>
+  new Promise((resolve, reject) => {
+    const timer = setTimeout(resolve, msec);
+    if (!signal) return;
+    signal.on('abort', () => {
+      clearTimeout(timer);
+      reject(new Error('Delay aborted'));
+    });
+  });
+
 module.exports = {
   random,
   sample,
@@ -179,4 +189,5 @@ module.exports = {
   parseCookies,
   createAbortController,
   timeout,
+  delay,
 };

test/timeout.js → test/async.js

@@ -1,7 +1,7 @@
 'use strict';
 
 const metatests = require('metatests');
-const { timeout, createAbortController } = require('..');
+const { timeout, delay, createAbortController } = require('..');
 
 metatests.test('Abortable timeout', async (test) => {
   try {
@@ -22,3 +22,23 @@ metatests.test('Abortable timeout', async (test) => {
     test.end();
   }
 });
+
+metatests.test('Abortable delay', async (test) => {
+  try {
+    const res = await delay(10);
+    test.strictSame(res, undefined);
+  } catch (err) {
+    test.error(new Error('Should not be executed'));
+  }
+  const ac = createAbortController();
+  setTimeout(() => {
+    ac.abort();
+  }, 10);
+  try {
+    await delay(100, ac.signal);
+    test.error(new Error('Should not be executed'));
+  } catch (err) {
+    test.strictSame(err.message, 'Delay aborted');
+    test.end();
+  }
+});