将多个文件上传到Firebase存储，并在所有上传完成后订阅forkJoin

<script src="https://www.gstatic.com/firebasejs/9.0.0/firebase-app.js"></script>
<script src="https://www.gstatic.com/firebasejs/9.0.0/firebase-storage.js"></script>

// 初始化Firebase SDK
const firebaseConfig = {
  apiKey: "YOUR_API_KEY",
  authDomain: "YOUR_AUTH_DOMAIN",
  projectId: "YOUR_PROJECT_ID",
  storageBucket: "YOUR_STORAGE_BUCKET",
  appId: "YOUR_APP_ID"
};

firebase.initializeApp(firebaseConfig);

// 获取存储引用
const storageRef = firebase.storage().ref();

// 获取文件选择器元素
const fileInput = document.getElementById("file-input");

// 监听文件选择器的change事件
fileInput.addEventListener("change", (event) => {
  // 获取用户选择的文件
  const file = event.target.files[0];

  // 创建一个存储引用，指定上传的文件名
  const fileRef = storageRef.child(file.name);

  // 将文件上传到Firebase存储
  const uploadTask = fileRef.put(file);

  // 监听上传任务的状态变化
  uploadTask.on("state_changed",
    (snapshot) => {
      // 上传进度
      const progress = (snapshot.bytesTransferred / snapshot.totalBytes) * 100;
      console.log(`上传进度：${progress}%`);
    },
    (error) => {
      // 上传错误处理
      console.error("上传错误：", error);
    },
    () => {
      // 上传完成处理
      console.log("上传完成");

      // 在所有上传完成后订阅forkJoin
      // 这里可以进行其他操作，比如通知用户上传完成等
    }
  );
});

import { forkJoin } from 'rxjs';

// 创建一个空的Observable数组
const observables = [];

// 将每个上传任务的Observable对象添加到数组中
observables.push(uploadTask);

// 使用forkJoin订阅所有Observable对象
forkJoin(observables).subscribe(
  () => {
    // 所有上传任务完成后执行的操作
    console.log("所有文件上传完成");
  },
  (error) => {
    // 错误处理
    console.error("上传错误：", error);
  }
);