function readFile() { return new Promise(function (resolve, reject) { let totalLines = 0; var s=fs.createReadStream("/var/www/uploads/"+filename); s.pipe(es.split()) .pipe( es.map(function (line, cb) { cb(customFunction(line)) }) .on("error", function (err) { reject(err); }) .on("end", function () { resolve("ok"); }) ); }) } function customFuntion(line){ async()=>{ var res=await redisClient.get(line); console.log(res) }(); }

Estoy leyendo un archivo de prueba grande usando createReadstream y flujo de eventos. El problema al que me enfrento es que quiero verificar cada número en la línea en redis, pero el archivo de lectura se completa antes de que mi consola inicie sesión en mi función personalizada.