Function testPipeToPreventClose

test/parallel/test-stream-iter-pipeto.js:37–47

()

}

async function testPipeToPreventClose() {
  let endCalled = false;
  const writer = {
    async write() {},
    async end() { endCalled = true; },
    async fail() {},
  };

  await pipeTo(from('data'), writer, { preventClose: true });
  assert.strictEqual(endCalled, false);
}

// PipeTo source error calls writer.fail()
async function testPipeToSourceError() {