Блог

У меня есть следующий случай, когда у меня есть data.txt , содержащий тысячи строк.

Моя цель — прочитать каждую строку этого файла, получить некоторые данные и сохранить их в массиве. Я использую readline и fs.createReadStream .

Вот что я сделал:

 const readingText = async () => {
  const fileStream = fs.createReadStream(
    "./data.txt"
  );

  const rl = readline.createInterface({
    input: fileStream,
    crlfDelay: Infinity
  });

  let dd = [];
  rl.on("line", line => {
    dd.push(line.split(":")[1]);
  });
  rl.on("close", async line => {
    console.log(dd);
    return dd;
  });
};

const someFunc = async () => {
  try {
    const ff = await readingText();
    console.log(ff);
  } catch (err) {
    console.log(err);
    return false;
  }
};

someFunc();
  

Проблема в том, что console.log(ff) всегда будет возвращаться, undefined пока console.log(dd) правильно возвращается требуемый dd массив, почему это? и как заставить console.log(ff) ждать, пока ff переменной будет присвоено значение dd массива?

Спасибо

Выполнение на основе событий не ожидает родительскую асинхронную функцию.

Попробуйте это:

 const readingText = async () => {
  return new Promise((resolve, reject) => {
    const fileStream = fs.createReadStream(
      "./data.txt"
    );

    const rl = readline.createInterface({
      input: fileStream,
      crlfDelay: Infinity
    });

    let dd = [];
    rl.on("line", line => {
      dd.push(line.split(":")[1]);
    });
    rl.on("close", line => {
      console.log(dd);
      return resolve(dd);
    });
  });

};

const someFunc = async () => {
  try {
    const ff = await readingText();
    console.log(ff);
  } catch (err) {
    console.log(err);
    return false;
  }
};

someFunc();