Блог

Здесь я использую модуль Readline внутри функции, которая выполняет функцию обратного вызова в.close. Он выполняется в ожидаемом порядке (код на.close, затем код в обратном вызове, переданный ему, это можно увидеть с помощью консоли.операторы журнала), однако копируется только часть конечного массива (как если бы часть кода не завершила выполнение вовремя).

Пример вывода:

 First: First Thing, 1, Second Thing, 2, Third Thing 3
Second: First Thing, 1
 

Как я могу получить эту строку кода:

 console.log("Second: "   result);
 

выполнять как с копированием всего массива (не перемещая все это в одну функцию или используя async / await)?

 ////////// Required Packages and Initialization //////////
var express = require("express");
var fs = require("fs");
var readline = require("readline");
var app = express();

app.use(express.static(__dirname   '/some_folder'));

app.listen(3000);

////////// Request Handler //////////
app.get("/some_request", function(req, res) {
    req.setTimeout(20000);
    input_data = ["First thing", "Second thing", "Third thing"]; // Already in alphabetical order
    file_search(input_data, "a_file.csv", function(output_data) {
        res.json(output_data);
    });
});

////////// Functions //////////
function file_search(name_array, FileName, callback)
{
    csv_fetch_array(name_array, FileName, function(result) {
        console.log("Second: "   result);  // Executes second as expected, but does not contain whole result array, cut short <-----
        callback(result);
    });
}

function csv_fetch_array(name_array, FileName, callback)
{
    var cntr = 0;
    var result = [];
    var len = name_array.length;

    if (!(FileName))
    {
        callback(result);
    }

    var file_stream = fs.createReadStream(__dirname   '/some_folder/'   FileName);

    file_stream.on('error', function (err) {
        callback(result);
    });

    var csv_file = readline.createInterface({
        input: file_stream
    });

    // csv file arranged in alphabetical order
    csv_file.on('line', function (line) {
        var search = line.split(",");
        var name_search = search[0];

        ///// Logic to hop to next phrase if past current one alphabetically /////
        if (name_search == name_array[cntr])
        {
            result.push(search);
            if (  cntr >= len)
            {
                csv_file.close();
                csv_file.removeAllListeners(); // Otherwise readline continues to empty buffer
            }
        }
        else if (name_search > name_array[cntr])
        {
            if (  cntr >= len)
            {
                csv_file.close();
                csv_file.removeAllListeners();
            }
            else if(name_search == name_array[cntr])
            {
                result.push(search);
                if (  cntr >= len)
                {
                    csv_file.close();
                    csv_file.removeAllListeners();
                }
            }
        }
    });

    csv_file.on('close', function() {
        console.log("First: "   result); // Correct result here, executes first <-----
        callback(result);
    });
}