Node.js встроенный модуль readline продолжает читать строки после закрытия - PullRequest
Новая
       4

Node.js встроенный модуль readline продолжает читать строки после закрытия

0 голосов
/ 01 марта 2020

У меня есть следующий код: 

const fs = require("fs");
const {createInterface} = require("readline");
const {join} = require("path");
const {once} = require("events");

async function readMeta (path) {
    const meta = {};
    const rs = fs.createReadStream(path);
    const lineReader = createInterface({input: rs});

    let linesRead = 0;

    lineReader.on("line", line => {

        switch (linesRead) {
            case 0:
                meta.name = line;
                break;
            case 1:
                meta.tags = line.split(" ");
                break;
            case 2:
                meta.type = line;
                break;
            case 3:
                meta.id = +line;
        }

        if (++linesRead === 4) {
            lineReader.close();
        }
    });
    await once(lineReader, "close");
    rs.close();
    return meta;
}

Кажется, он работает, но регистрация строк, когда срабатывает событие line, показывает обратное. Событие по-прежнему вызывается после вызова lineReader.close(), в результате чего читается весь файл. Я понятия не имею, что вызывает это. Я нашел несколько модулей, которые, по-видимому, справляются с этой задачей, но я хочу сохранить зависимости, если возможно.

1 Ответ

0 голосов
/ 01 марта 2020

Вместо обработки и переключения счетчика я рекомендую использовать pu sh строк в массиве и предотвратить дальнейшее pu sh -ing после того, как размер массива равен 4.

Затем вызвать close и после, чтобы деструктурировать массив до необходимые атрибуты и возвращаемый объект, который их содержит. 

const fs = require("fs");
const {createInterface} = require("readline");
const {join} = require("path");
const {once} = require("events");

async function readMeta (path) {
    const meta = {};
    const rs = fs.createReadStream(path);
    const lineReader = createInterface({input: rs});

    const linesRead = [];

    lineReader.on("line", line => {
      if (linesRead.length === 4) {
        lineReader.close();
        rs.close();
        return;
      }
      linesRead.push(line.trim());
    });

    await once(lineReader, "close");
    delete rs;
    delete lineReader;

    const [name, tags, type, id] = linesRead;
    return {
      id,
      name,
      type,
      tags: tags.split(' '),
    };
}
...