避免嵌套订阅：RxJS顺序API调用加延迟后的问题解决

安全阿岳

2026-8-2

问题分析

你之前的错误在于：this.getUsers(key)本身就是一个Observable，用of()包装后返回的变成了Observable<Observable<T>>，所以subscribe拿到的是内部Observable而非实际数据。而且of(this.getUsers(key))会立即触发API调用，延迟1秒后才吐出这个已经在执行的Observable，根本达不到“API调用之间延迟”的预期效果。

正确写法

写法1：API返回后延迟1秒，再执行下一个调用

这是最贴合需求的写法——前一个API请求完成后，等待1秒再发起下一个，严格保持顺序：

from(Object.keys(someObj))
  .pipe(
    concatMap(key => this.getUsers(key).pipe(delay(1000)))
  )
  .subscribe(res => {
    // 这里拿到的是每个API返回的实际数据
  })

concatMap会自动等待前一个Observable（即getUsers(key).pipe(delay(1000))）完成后，才会处理下一个key，完美保证顺序和延迟效果。

写法2：先延迟1秒，再发起API调用

如果需要先等1秒再触发API请求（而非API返回后等待），可以这么写：

from(Object.keys(someObj))
  .pipe(
    concatMap(key => of(key).pipe(
      delay(1000),
      switchMap(key => this.getUsers(key))
    ))
  )
  .subscribe(res => {
    // 处理返回数据
  })

这种写法会先对每个key延迟1秒，再发起对应的API请求，同样严格保持顺序。