ノード（express.js）は、ストリーム

Question

の終了前に呼び出され、私は、次のミドルウェア機能

var bodyParser = require('body-parser'), 
    fs = require('fs'); 
module.exports = function(req, res, next) { 
    // Add paths to this array to allow binary uploads 
    var pathsAllowingBinaryBody = [ 
    '/api2/information/upload', 
    '/api2/kpi/upload', 
    ]; 

    if (pathsAllowingBinaryBody.indexOf(req._parsedUrl.pathname) !== -1) { 
    var date = new Date(); 
    req.filePath = "uploads/" + date.getTime() + "_" + date.getMilliseconds() + "_" + Math.floor(Math.random() * 1000000000) + "_" + parseInt(req.headers['content-length']); 

    var writeStream = fs.createWriteStream(req.filePath); 
    req.on('data', function(chunk) { 
     writeStream.write(chunk); 
    }); 
    req.on('end', function() { 
     writeStream.end(); 
     next(); 
    }); 
    } else { 
    bodyParser.json()(req, res, next); 
    } 
}; 

ファイルが正しく転送されているいるが、悲しいことに

req.on('end', function() { 
    writeStream.end(); 
    next(); 
}); 

でnext()すべてのデータを新しいファイルに書き込む前に呼び出されます。

私の質問は何ですか？そして私はそれをどのように修正できますか？

Answer 1

書き込み可能ファイルストリームのcloseイベントを使用して、ファイル記述子がいつ閉じられたかを知ることができます。

これを置き換えます。これで

var writeStream = fs.createWriteStream(req.filePath); 
req.on('data', function(chunk) { 
    writeStream.write(chunk); 
}); 
req.on('end', function() { 
    writeStream.end(); 
    next(); 
}); 

を：

req.pipe(fs.createWriteStream(req.filePath)).on('close', next);