问提供数据处理方面的进展

EN

我已经编写了一个Node包，它执行一些密集的数据处理。我可以通过console.log查看进度，但我希望为最终用户提供一些以事件驱动的方式进行监控的方法。基本上，它类似于返回一个promise，除了每个“步骤”都有一个事件而不是一个then事件，然后最终使用数据进行解析。

不幸的是，我对Node streams (我猜这是我需要的东西)了解不够，无法做到这一点。我能得到一些建议吗？我如何创建一个流，该流在每次进度增加1%时都会更新，然后最终给出计算数据？

EDIT:作为示例，请考虑以下循环：

for(let i = 0; i < N; i++) {
    intensiveFunction();
    console.log(`${i} of ${N} completed`);
}

我想要做的是

for(let i = 0; i < N; i++) {
    intensiveFunction();
    // send user a signal that i/N of the task has been completed
}