stream mess

1.js

const fs = require('fs')
const stream = require('stream')
const { promisify } = require('util')

const finished = promisify(stream.finished)


const handle = async (compare_object) => {
  for (let [key, item] of Object.entries(compare_object)) {
    var f = fs.createReadStream(item.local_path);
    f.on('data', function(buf) {
    });
    await finished(f)
    //here you call .digest
  }
}

handle(compare_object)