回調來處理管道的完成

Question

我正在使用以下node.js代碼從某個url下載文件並將其保存在磁盤中。 我想知道下載文檔的時間。我還沒有看到任何回調pipe.Or，是否有任何'結束'事件可以完成下載捕獲？

request(some_url_doc).pipe(fs.createWriteStream('xyz.doc')); 

Answer 1

流是EventEmitter所以你可以聽某些事件。正如你所說，有一個finish事件請求（以前的end）。

var stream = request(...).pipe(...); 
stream.on('finish', function() { ... }); 

有關哪些事件可用的更多信息，您可以檢查stream documentation page。

Answer 2

基於nodejs文件，http://nodejs.org/api/stream.html#stream_event_finish, 它應該處理writableStream的finish事件。

var writable = getWriteable(); 
var readable = getReadable(); 
readable.pipe(writable); 
writable.on('finish', function(){ ... }); 

Answer 3

將內容從管道通過http傳輸到文件系統的代碼片段。作爲@starbeamrainbowlabs注意到事件finish做工作

var tmpFile = "/tmp/somefilename.doc"; 

var ws = fs.createWriteStream(tmpFile); 
ws.on('finish', function() { 
    // pipe done here, do something with file 
}); 

var client = url.slice(0, 5) === 'https' ? https : http; 
client.get(url, function(response) { 
    return response.pipe(ws); 
}); 

Answer 4

，我發現我的問題，關於這方面的有點不同的解決方案。思想值得分享。

大部分示例都從文件創建readStreams。但在我的情況下，readStream必須由來自消息池的JSON字符串創建。

var jsonStream = through2.obj(function(chunk, encoding, callback) { 
        this.push(JSON.stringify(chunk, null, 4) + '\n'); 
        callback(); 
       }); 
// message.vale --> valeu/text to write in write.txt 
jsonStream.write(JSON.parse(message.value)); 
var writeStream = sftp.createWriteStream("/path/to/write/write.txt"); 

//"close" event didn't work for me! 
writeStream.on('close', function() { 
    console.log("- done!"); 
    sftp.end(); 
    } 
); 

//"finish" event didn't work for me either! 
writeStream.on('close', function() { 
    console.log("- done!" 
     sftp.end(); 
     } 
); 

// finally this worked for me! 
jsonStream.on('data', function(data) { 
    var toString = Object.prototype.toString.call(data); 
    console.log('type of data:', toString); 
    console.log("- file transferred"); 
}); 

jsonStream.pipe(writeStream); 

Answer 5

下面是在處理請求的錯誤，並調用文件被寫入後回調的解決方案：

request(opts) 
    .on('error', function(err){ return callback(err)}) 
    .pipe(fs.createWriteStream(filename)) 
    .on('finish', function (err) { 
     return callback(err); 
    });