Function catchesErrorsWithAbortSignal

test/parallel/test-events-once.js:61–85

()

}

async function catchesErrorsWithAbortSignal() {
  const ee = new EventEmitter();
  const ac = new AbortController();
  const signal = ac.signal;

  const expected = new Error('boom');
  let err;
  process.nextTick(() => {
    ee.emit('error', expected);
  });

  try {
    const promise = once(ee, 'myevent', { signal });
    assert.strictEqual(ee.listenerCount('error'), 1);
    assert.strictEqual(listenerCount(signal, 'abort'), 1);

    await promise;
  } catch (e) {
    err = e;
  }
  assert.strictEqual(err, expected);
  assert.strictEqual(ee.listenerCount('error'), 0);
  assert.strictEqual(ee.listenerCount('myevent'), 0);
  assert.strictEqual(listenerCount(signal, 'abort'), 0);
}

async function stopListeningAfterCatchingError() {
  const ee = new EventEmitter();