Function readStream

lib/utils/asyncUtils.js:21–32

(stream)

}

function readStream(stream) {
    return new Promise((resolve, reject) => {
        let data = '';
        stream.on('data', (chunk) => {
            data += chunk;
        });
        stream.on('end', () => {
            resolve(data);
        });
        stream.on('error', reject);
    });
}

function tapStream(originalStream, onData) {
    const tee = new PassThrough();