Function testPullWithAbortSignal

test/parallel/test-stream-iter-pull-async.js:43–58

()

}

async function testPullWithAbortSignal() {
  async function* gen() {
    yield [new Uint8Array([1])];
  }

  const result = pull(gen(), { signal: AbortSignal.abort() });
  await assert.rejects(
    async () => {
      // eslint-disable-next-line no-unused-vars
      for await (const _ of result) {
        assert.fail('Should not reach here');
      }
    },
    { name: 'AbortError' },
  );
}

async function testPullChainedTransforms() {
  const enc = new TextEncoder();