streamのendハンドラーの処理が終わってから、関数を終了させたい。

Question

前提

FirebaseのCloud FunctionsでBufferを返したい下記の関数があります。

exports.getBuffer = functions
  .runWith({
    timeoutSeconds: 10,
  })
  .https.onCall((aug, context) => {

  let chunks = [];
  const stream = getExampleStream(aug);

  stream.on("data", (data) => {
    chunks.push(data);
  });
  stream.on("error", (err) => {
    console.log(err);
  });
  stream.on("end", () => {
    const buf = Buffer.concat(chunks);
  });
};

実現したいこと

前述の"end"の関数でbufが生成されたらgetBuffer関数を終了し、getBuffer関数の呼び出し元にbufを返したいです。

試したこと・発生している問題

「Aが終わったら、Bを実行する」という処理を実現するためにネットで検索したところ、Promiseを使うとよい、という主旨をいくつかの記事で読み取りました。
そこで下記のように書いてみました。

const promise = new Promise((resolve, reject) => {
  stream.on("data", (data) => {
    chunks.push(data);
  });
  stream.on("error", (err) => {
    console.log(err);
    reject(err);
  });
  stream.on("end", () => {
    const buf = Buffer.concat(chunks);
    resolve(buf);
  });
};
return promise.then(buf => {
  return buf;
}).catch(err => {
  return err;
});

上記は書き方が悪かったのか、タイムアウトします。

上記のgetBuffer関数はonRequestの形式であれば機能しました。

  stream.on("data", (data) => {
    chunks.push(data);
  });
  stream.on("error", (err) => {
    console.log(err);
    res.status(400).json({err});
  });
  stream.on("end", () => {
    res.write(buffer);
    res.status(200).end();
  });

しかし、onRequestの形式だとAppCheckの対応が難しそうだったので、onCallの形式にしようとしています。