在前端开发中，我们时常需要操作流对象（Stream）。然而，操作流对象不是很方便，尤其是在一些异步操作中，我们经常需要在 Stream 结束后做一些处理，比如关闭文件句柄、向数据库中写入数据等。这时，我们不得不写大量的回调函数，代码可读性和可维护性都非常差。为了解决这个问题，出现了许多 npm 包，其中一款比较好用的就是 end-of-stream-promise。
end-of-stream-promise 简介
end-of-stream-promise 是一个在 Stream 结束时返回 Promise 对象的 npm 包，它可以减少异步回调函数的使用，使我们的代码更简洁易读。它的使用非常简单，只需要将 stream 对象传入 end-of-stream-promise 函数中，就可以得到一个 Promise 对象，该 Promise 会在 Stream 结束时 resolve。
end-of-stream-promise 安装
安装 end-of-stream-promise 可以使用 npm 命令：
npm install end-of-stream-promise
end-of-stream-promise 使用
使用 end-of-stream-promise 非常简单，只需要用它包装 Stream 对象即可。下面是一个例子：
-- -------------------- ---- -------
----- -- - --------------
----- ------------------ - ---------------------------------
----- ------ - --------------------------------
--------------------------
-------- -- -
---------------- ------ --- ---------
--
------------ -- -
----------------- ----- ----------- -----
---可以看到，我们只需要将 stream 对象传入 endOfStreamPromise 函数中，就可以得到一个 Promise 对象，该 Promise 对象会在 Stream 结束时 resolve。我们可以在 then 方法中做一些处理，比如关闭文件句柄、向数据库中写入数据等操作。
如果 Stream 发生了错误，Promise 对象会在 catch 方法中返回错误信息。
end-of-stream-promise 深度
end-of-stream-promise 内部实现了一个 readable-stream 的 Transform 流，用来监听 Stream 的 end 和 error 事件。当 Stream 结束时，Transform 流通过 resolve 方法将 Promise 对象 resolve，否则通过 reject 方法将 Promise 对象 reject。
Transform 流是一种读写转换流，它可以将一个 readable 流转换为一个 writable 流，相当于可读可写的中间件，它可以通过 pipe 方法连接到其他流中。
end-of-stream-promise 使用建议
使用 end-of-stream-promise 可以使我们的代码更简洁易读，但不能滥用。在一些场景下，使用回调函数可能更加合适，比如需要传递多个参数的情况。
另外，在使用 end-of-stream-promise 时，需要注意 Stream 对象是否正确关闭。如果 Stream 对象没有正确关闭，可能会造成内存泄漏或者文件句柄泄漏等问题。因此，我们需要在 then 方法中进行一些清理工作，比如关闭文件句柄、释放内存等。
示例代码
下面是一个使用 end-of-stream-promise 读取文件的示例代码：
-- -------------------- ---- -------
----- -- - --------------
----- ------------------ - ---------------------------------
----- ---------- - --------------------------------
--- ------- - ---
--------------------- ------ -- -
------- -- -----
---
------------------------------
-------- -- -
---------------- ---- ------- --- -------------
-------------------
--
------------ -- -
----------------- ----- --------- ---------
-------------------
---在该例子中，我们使用 end-of-stream-promise 包装了 Stream 对象，并通过 on('data') 方法监听 'data' 事件，将文件中的数据读出来。当 Stream 结束时，我们通过 then 方法输出文件内容，并关闭文件句柄。
总结
npm 包 end-of-stream-promise 在操作 Stream 对象时非常实用，通过它可以减少异步回调函数的使用，使我们的代码更加简洁易读。在使用时需要注意 Stream 对象是否正确关闭，避免出现内存泄漏等问题。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/the-end-of-the-stream-of-promise