Function testMergeObjectLikeSources

test/parallel/test-stream-iter-consumers-merge.js:169–187

()

// merge() accepts object-like sources that are normalized via from()
async function testMergeObjectLikeSources() {
  const arrayBuffer = new TextEncoder().encode('abc').buffer;
  const dataView = new DataView(new TextEncoder().encode('def').buffer);
  const streamable = {
    [toStreamable]() {
      return 'ghi';
    },
  };
  const asyncStreamable = {
    [toAsyncStreamable]() {
      return Promise.resolve('jkl');
    },
  };

  assert.strictEqual(await text(merge(arrayBuffer)), 'abc');
  assert.strictEqual(await text(merge(dataView)), 'def');
  assert.strictEqual(await text(merge(streamable)), 'ghi');
  assert.strictEqual(await text(merge(asyncStreamable)), 'jkl');
}

// =============================================================================
// Merge cleanup error handling