我有以下问题：
我使用NodeJS流和管道来读取一个大文件，做一些转换，然后将其写入可写流。棘手的部分是，如果满足特定条件，我希望能够停止阅读文件，但仍然完成处理已经读取的块。
在下面的示例中，我正在阅读一个文本文件，我的转换流（secondStream）将文本转换为大写并发送到下一个流。但是如果它找到了一个文本，这意味着它应该停止从文本文件中阅读，我相信这意味着readstream应该停止读取块。
我尝试了几种解决方案，但不会线，我有点困惑在这里。到目前为止，我得到了以下代码。但是，通过使用firstStream.destroy();会使管道抛出错误
Error [ERR_STREAM_PREMATURE_CLOSE]: Premature close
我能够通过在管道上捕获并忽略它来“避免”这个错误，但老实说，这对我来说听起来并不安全或正确。

const { Transform, Writable, Readable } = require("node:stream");
  const { pipeline } = require("node:stream/promises");
  const fs = require("node:fs");

  let shouldStop = false;
  const firstStream = fs.createReadStream("./lg.txt");

  const secondStream = new Transform({
    transform(chunk, encoding, callback) {
      const foundText = chunk.toString().search("CHAPTER 9") !== -1;

      if (foundText) {
        shouldStop = true;
      }

      const transformed = chunk.toString().toUpperCase();
      callback(null, transformed);
    },
  });

  const lastStream = process.stdout;

  firstStream.on("data", () => {
    if (shouldStop) {
      console.log("should pause");
      firstStream.destroy();
    }
  });

  await pipeline(firstStream, secondStream, lastStream).catch(
    (err) => undefined
  ); // Feels wrong to me

有更好的办法吗？我错过什么了吗？
提前感谢各位朋友！