Function testDestroyAsync

test/parallel/test-stream-iter-to-readable.js:142–171

()

// =============================================================================

async function testDestroyAsync() {
  let returnCalled = false;
  async function* gen() {
    try {
      for (let i = 0; ; i++) {
        yield [Buffer.from(`chunk${i}`)];
      }
    } finally {
      returnCalled = true;
    }
  }

  const readable = toReadable(gen());

  // Read a couple chunks then destroy
  const chunks = [];
  await new Promise((resolve, reject) => {
    readable.on('data', (chunk) => {
      chunks.push(chunk);
      if (chunks.length >= 3) {
        readable.destroy();
      }
    });
    readable.on('close', resolve);
    readable.on('error', reject);
  });

  assert.ok(chunks.length >= 3);
  assert.ok(returnCalled, 'iterator.return() should have been called');
}

// =============================================================================
// fromStreamIter: destroy while pump is waiting on backpressure