Wie man einen nodejs LineInputStream stoppt?

Question

Ich verarbeite eine CSV-Datei und wenn ich einen Validierungsfehler gefunden habe und möchte das Skript die Verarbeitung von Zeilenumbrüchen beenden.

router.use(upload.single('csv')).route('/agency/:agencyId/properties/import').post(function (req, res) { 

    var stream = LineInputStream(fs.createReadStream(req.file.path, {flags: 'r'})); 
    stream.setDelimiter("\n"); 

    stream.on('line', function(line) { 
    var row = line.split(','); 
    if (row.length!=15) { 
     stream.end(); // this does not stop the processing of new lines 
     return res.status(400).json({error: 'File should have 15 columns.'}); 
    } 
    }); 

}); 

Answer 1

Verwenden stream.destroy() innerhalb der Linie Handler-Funktion und dann eine Fehlerbehandlungsroutine zu dem Strom anschließen, die eine Fehlerantwort zurück.

Siehe How to close a readable stream (before end)?