合适的GZIP流

Question

我正在尝试创建一个可以在其他地方重复使用的GZIP流。 GZIP可以很好地压缩数据流，但我想重构我的代码，以便可以分开关注。这样一来，我最终得到了以下内容。但是，我无法利用返回的流。

const zlib = require('zlib');

function compress(stream) {
  return new Promise((resolve, reject) => {
    const gzipStream = zlib.createGzip();

    gzipStream.on('end', () => {
      resolve(gzipStream);
    });

    gzipStream.on('error', (e) => {
      reject(e);
    });

    stream.pipe(gzipStream);
  });
}

但是，当我使用返回的流时，我将获得空输出。例如，我压缩一个充满0的50MB文件，使用新功能后，我将获得一个空文件。

async function handler(req, res) {
  const fileStream = fs.createReadStream("./test_50m");
  const compressedStream = await compress(fileStream);
  
  compressedStream.pipe(fs.createWriteStream("./test_50m_output"));
}

谢谢