Function testDestroySync

test/parallel/test-stream-iter-to-readable.js:493–511

()

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

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

  const readable = toReadableSync(gen());
  readable.read();  // Start iteration
  readable.destroy();

  await new Promise((resolve) => readable.on('close', resolve));
  assert.ok(returnCalled, 'iterator.return() should have been called');
}

// =============================================================================
// fromStreamIterSync: not object mode