Function testConsumerThrowRejectsWrites

test/parallel/test-stream-iter-push-writer.js:279–291

()

// Consumer throw causes subsequent writes to reject with consumer's error
async function testConsumerThrowRejectsWrites() {
  const { writer, readable } = push({ highWaterMark: 1 });
  writer.writeSync('a');

  const iter = readable[Symbol.asyncIterator]();
  await iter.throw(new Error('consumer boom'));

  // Subsequent async writes should reject with the consumer's error
  await assert.rejects(
    () => writer.write('x'),
    { message: 'consumer boom' },
  );
}

// end() resolves a pending read as done:true
async function testEndResolvesPendingRead() {