重复Rxjs，直到要处理的项目为零

import { of } from 'rxjs';
import { delay, repeat, takeWhile } from 'rxjs/operators';

// 模拟异步任务的执行
function processTask(task: any): Promise<any> {
  return new Promise(resolve => {
    // 模拟异步操作
    setTimeout(() => {
      console.log(`处理任务: ${task}`);
      resolve(task);
    }, Math.random() * 1000);
  });
}

// 模拟一批异步任务
const tasks = [1, 2, 3, 4, 5];

// 创建一个Observable，用于处理异步任务
const task$ = of(...tasks).pipe(
  // 使用concatMap操作符依次处理任务
  concatMap(task => processTask(task)),
  // 使用delay操作符模拟任务执行的时间
  delay(1000),
  // 使用takeWhile操作符判断是否还有未处理的任务
  takeWhile(() => tasks.length > 0),
  // 使用repeat操作符重复执行Observable的订阅，直到要处理的项目为零
  repeat()
);

// 订阅Observable，开始处理异步任务
task$.subscribe({
  next: task => {
    // 任务处理完成后的操作
    console.log(`任务处理完成: ${task}`);
    tasks.pop(); // 从任务列表中移除已处理的任务
  },
  complete: () => {
    console.log('所有任务处理完成');
  }
});