Function collect

test/parallel/test-stream-iter-to-readable.js:19–26

(readable)

} = require('stream/iter');

function collect(readable) {
  return new Promise((resolve, reject) => {
    const chunks = [];
    readable.on('data', (chunk) => chunks.push(chunk));
    readable.on('end', () => resolve(Buffer.concat(chunks)));
    readable.on('error', reject);
  });
}

// =============================================================================
// fromStreamIter: basic async round-trip