createReadStream() se ejecuta en paralelo. Entonces, después de llamar a esta función, el programa continúa y el siguiente proceso es su consola.log(a). Esa es la idea detrás de las secuencias porque el programa puede continuar ejecutándose mientras se lee el archivo grande.

El código dentro de las funciones .on() se llama más tarde. Es por eso que se llaman "devoluciones de llamada".

Así que está registrando el resultado antes de que se lea cualquier dato...

Como se explicó antes, la corriente principal se ejecuta en segundo plano. Puede envolver la transmisión en una promesa para obtener el resultado. Aquí hay una posible solución:

 const fs = require('fs'); const { parse } = require('csv-parse'); const readFile = async () => new Promise((resolve, reject) => { let a = []; fs.createReadStream('./example.csv') .pipe(parse({ delimiter: ';', from_line: 2 })) .on('data', function (row) { a.push(row); }) .on('end', function () { resolve(a); }) .on('error', function (error) { reject(error) }); }); readFile().then(data => console.log(data))

Su a no está undefined porque el código se ejecuta de forma asíncrona. La función on() se llama después de que se ejecuta su console.log(a) .

Puede leer el valor de a evento dentro de los data o el evento end :

 fs.createReadStream('./example.csv') .pipe(parse({ delimiter: ';', from_line: 2 })) .on('data', function (row) { a.push(row); console.log(a) // <------- here }) .on('end', function () { console.log('finished'); console.log(a) // <------- here }) .on('error', function (error) { console.log(error.message); });

Una solución puede ser usar una Promise

 const readCSVData = async () => new Promise((resolve, reject) => { let a = [] fs.createReadStream('./example.csv') .pipe(parse({ delimiter: ';', from_line: 2 })) .on('data', function (row) { a.push(row); }) .on('end', function () { // return the a value resolve(a) }) .on('error', function (error) { reject(error) }); }) // ..... const foo = async () => { const data = await readCSVData() console.log(data) } // or readCSVData().then(a => console.log(a))