如何实现每隔3秒发送请求，全部请求发送完成后自动停止？

你当前的代码是一次性把所有请求都加入数组，没有实现间隔发送的逻辑。要达到每隔3秒发一次请求、全部完成后自动停止的效果，可以用异步迭代+延迟控制的方式来处理，下面是具体实现方案：

步骤1：封装延迟函数 #

先写一个简单的延迟函数，把setTimeout包装成Promise，方便配合async/await控制间隔：

private delay(ms: number): Promise<void> {
  return new Promise(resolve => setTimeout(resolve, ms));
}

步骤2：修改请求发送逻辑 #

用异步函数遍历candies数组，逐个发送请求，每发完一个就等待3秒（最后一个请求不需要额外等待）：

async sendRequestsWithInterval() {
  const requestResults = [];
  
  for (const element of candies) {
    try {
      // 发送请求并等待结果，这里假设getCandy返回Promise；如果是Observable需要转成Promise（看下方说明）
      const result = await this.service.getCandy(element.user);
      requestResults.push(result);
      console.log(`用户${element.user}的请求已完成`);
    } catch (err) {
      console.error(`用户${element.user}的请求失败`, err);
      // 可选：如果不想因为单个请求失败中断整个流程，这里直接跳过即可
    }

    // 最后一个请求不需要等待，避免多余的3秒延迟
    if (element !== candies[candies.length - 1]) {
      await this.delay(3000);
    }
  }

  console.log('所有请求已全部完成', requestResults);
}

注意：如果getCandy返回Observable（比如Angular HttpClient） #

如果你的service.getCandy返回的是RxJS Observable，需要先转换成Promise才能用await：

// RxJS 7+推荐用firstValueFrom
import { firstValueFrom } from 'rxjs';

// 在循环里替换成：
const result = await firstValueFrom(this.service.getCandy(element.user));

这样就能严格按照每隔3秒发送一次请求，直到所有请求都处理完毕后自动停止流程。

内容的提问来源于stack exchange，提问作者user19888272