实现自定义可观察类型的延迟答案

【问题标题】：Achieving delay for custom observable types实现自定义可观察类型的延迟
【发布时间】：2020-07-10 10:19:29
【问题描述】：

我有一个延迟 1 秒的可观察数字。

const obsNums = from([...Array(100).keys()])
obsNums.pipe(delayWhen((x: number) => timer(x * 1000))).subscribe(x => console.log(x))

我们可以用自定义类型实现类似的东西吗？

const obsCus = from(this.item$ = this.getItems())

  getItems(): Observable<any> {
    return this.http.get<Observable<any>>('https://jsonplaceholder.typicode.com/users')
  }

obsCus.pipe(delayWhen((usr: user) => timer(usr * 1000))).subscribe(usr => console.log(usr))

这里的想法是像数字数组一样将用户延迟一秒。

【问题讨论】：

【解决方案1】：

使用concatMap 以一秒的延迟将用户提供给流

getItems().pipe(
switchMap(users=>from(users))
concatMap(user=>timer(1000).pipe(mapTo(user)))
)

【讨论】：