yo-data-processing

A module that I wrote to process dagta using nodejs stream.

Install and Usage

npm i yo-data-processing

import { getFiles } from 'yo-data-processing/stream';

const stream = getFiles(dirData)
    .on('readable', () => {
        let file;

        while (null != (file = stream.read())) {
            countFiles++;
            console.(`file name => ${file}`);
        }
    })
    .on('end', () => {
        console.log('finish');
    })
    .on('error', (err) => {
        console.error(err);
    });