Как проверить завершение цепи трубопровода в node.js?

Question

Например, у меня есть это:

var r = fs.createReadStream('file.txt'); 
var z = zlib.createGzip(); 
var w = fs.createWriteStream('file.txt.gz'); 
r.pipe(z).pipe(w); 

Я хочу сделать что-то после r.pipe (г) .pipe (ш) заканчивается. Я пробовал что-то вроде этого:

var r = A.pipe(B); 
r.on('end', function() { ... }); 

но он не работает для цепи труб. Как я могу заставить его работать?

Answer 1

Вы ищете событие finish. Из docs:

Когда метод конечной() был вызван, и все данные были записаны на базовую систему, это событие испускается.

Когда поток источник испускает end, он вызывает end() по назначению, что в вашем случае является B. Так вы можете сделать:

var r = A.pipe(B); 
r.on('finish', function() { ... });