Function testErrorSync

test/parallel/test-stream-iter-to-readable.js:459–473

()

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

async function testErrorSync() {
  function* gen() {
    yield [Buffer.from('ok')];
    throw new Error('sync source failed');
  }

  const readable = toReadableSync(gen());

  await assert.rejects(async () => {
    // eslint-disable-next-line no-unused-vars
    for await (const chunk of readable) {
      // Consume until error
    }
  }, { message: 'sync source failed' });
}

// =============================================================================
// fromStreamIterSync: empty source