在节点 js 读取流上调用 readStream.destroy() 不会停止读取

Question

我希望你们都做得很好。我在 Node Js 中遇到了流问题，我想请求您的帮助：我正在阅读一个文件： const readStream = fs.createReadStream('./veryBigFile');我将输出通过管道发送到一个 POST 请求，如下所示：readStream.pipe(post_req);但是，我想在一定超时后停止读取文件，并停止 POST 请求。我尝试了 readStream.close() 和 readStream.destroy() 但它们不起作用（我将一个“结束”侦听器附加到 readStream，它在超时后不会被触发）。有任何想法吗 ？

Answer 1

在您对 kirill Groshkov 发表评论后，我决定再次查看我的代码，我了解如何使其工作！

在触发销毁事件（使用 readStream.destroy()）之后，发出的是“错误”事件，而不是我正在收听的“结束”事件。

所以我仍然必须使用 readStream.destroy('YOUR CUSTOM ERROR MESSAGE') 在超时后停止读取文件。

然后我听了这个自定义错误：

        readStream.on('error', e => {

        if (e === 'YOUR CUSTOM ERROR MESSAGE') {

            post_req.abort(); //To cancel request

            // etc.

        } else {

            reject(`An error occured while uploading data: ${e}`);

        }

    });