Function testErrorPropagation

test/parallel/test-stream-iter-readable-interop.js:174–185

()

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

async function testErrorPropagation() {
  const readable = new Readable({
    read() {
      process.nextTick(() => this.destroy(new Error('test error')));
    },
  });

  await assert.rejects(
    text(from(readable)),
    (err) => err.message === 'test error',
  );
}

// =============================================================================
// Byte-mode Readable: with transforms