Как следить за процессом работы потока в %?

Question

[adsprosto]

lollyrock.com/articles/nodejs-encryption
Здесь описано, как шифровать содержимое из потока, возможно, ссылка не по теме, но как отследить состояние потока функции pipe именно в %?

Answer 1

[Aves]

Можно сделать что-нибудь в таком роде:

const stream = require('stream');
const fs = require('fs');

class PercentWatcher extends stream.Duplex {
  constructor(fd) {
    super();
    this.size = fs.fstatSync(fd).size;
    this.handled = 0;
  }
  _read() {}
  _write(chunk, encoding, callback) {
    this.push(chunk);
    this.handled += chunk.length;
    console.log(`\n\n${Math.round(this.handled / this.size * 100)}%\n\n`);
    callback();
  }
}

const fd = fs.openSync('file.txt', 'r');

fs.createReadStream(null, {fd}).pipe(new PercentWatcher(fd)).pipe(process.stdout);

Comments

[adsprosto]

Можешь поподробнее?? Мне нужно узнавать от записанного, а не от читаемого
fs.createReadStream(null,{fd}).pipe(zip).pipe(encrypt).pipe(fs.createWriteStream('1.txt'));

[Aves]

adsprosto: чтобы считать проценты, нужно знать, сколько составляет 100%, а тут размер записываемого файла заранее неизвестен. Можно добавить промежуточный stream между encrypt и writeStream и выводить килобайты.
Но pipe по сути выстраивает потоки в единый поток, и размер записанного прямо пропорционален размеру прочитанного, с относительно небольшим разбросом, так что проценты вполне можно считать и по прочитанному, это будет довольно близко к правде.