Function tapStream

lib/utils/asyncUtils.js:34–47

(originalStream, onData)

}

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

    let data = '';
    tee.on('data', (chunk) => {
        data += chunk;
    });
    tee.on('end', () => {
        onData(data);
    });

    return tee; // Use this stream for downstream consumers
}

export { readFromStream, tapStream, readStream };
export default {