الموثوقية والإغلاق المنضبط

import { setTimeout as delay } from 'node:timers/promises';
let attempts = 0;
async function dependency() {
  attempts++;
  if (attempts === 1) { const error = new Error('Temporary'); error.code = 'TRANSIENT'; throw error; }
  return 'ok';
}
async function run() {
  for (let attempt = 1; attempt <= 3; attempt++) {
    try { return await dependency(); }
    catch (error) {
      if (error.code !== 'TRANSIENT' || attempt === 3) throw error;
      await delay(1);
    }
  }
}
console.log(await run(), attempts);

ok 2

الرمز TRANSIENT وحده قابل للتكرار وعدد المحاولات محدود. تقبل الدالة الفعلية أيضا موعدا نهائيا وإشارة إلغاء.

import { createServer } from 'node:http';
import { once } from 'node:events';
let ready = true;
let closing;
const server = createServer((req, res) => { res.end('ok'); });
function shutdown() {
  if (!closing) {
    ready = false;
    closing = new Promise((resolve, reject) => server.close(e => e ? reject(e) : resolve()));
  }
  return closing;
}
server.listen(0, '127.0.0.1'); await once(server, 'listening');
try {
  const response = await fetch(`http://127.0.0.1:${server.address().port}`);
  console.log(await response.text());
} finally {
  const a = shutdown(); const b = shutdown();
  console.log(ready, a === b); await a;
}
console.log('stopped');

ok
false true
stopped

يغير التصريف الجاهزية ويعيد وعد إغلاق واحدا. تُستهلك الاستجابة المحلية قبل إغلاق المستمع.