Function testPullAsyncSABChunks

test/parallel/test-stream-iter-sharedarraybuffer.js:142–154

()

}

async function testPullAsyncSABChunks() {
  async function* gen() {
    const sab = new SharedArrayBuffer(2);
    new Uint8Array(sab).set([3, 4]);
    yield [new Uint8Array(sab)];
  }
  const batches = [];
  for await (const batch of pull(gen())) {
    batches.push(batch);
  }
  assert.strictEqual(batches.length, 1);
  assert.deepStrictEqual(batches[0][0], new Uint8Array([3, 4]));
}

// =============================================================================
// Transform returning SAB