代码之家 › 专栏 › 技术社区 › nks

我可以将setTimeout方法转换为observable.timer吗?

observable timer angular

nks · 技术社区 · 6 年前

听说我在迭代数组,我想每2秒运行一次这个循环。

 let Array = [1,2,3,4,5,6]  
      for (i = 0; i < Array.length; i++) {
          setTimeout((item)=>{
           //business logic
          console.log("item", item);
          }, 2000 * i, Array[i]);
    }

如何在observable.timer方法中转换此代码?

2 回复 | 直到 6 年前

tkausl 6 年前

这应该有效:

    let Array = [1,2,3,4,5,6]
rxjs.interval(2000)
.pipe(
    rxjs.operators.take(Array.length),
    rxjs.operators.map(i => Array[i])
).subscribe(value => console.log(value));

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.3.3/rxjs.umd.min.js"></script>

之后自动结束 Array.length 项目( take )并生成subscribe中的项( map )而不是他们的索引。

RXJS v5版本:

    let Array = [1,2,3,4,5,6]
Rx.Observable.interval(2000)
.take(Array.length)
.map(i => Array[i])
.subscribe(value => console.log(value));

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.5.12/Rx.min.js"></script>

zhimin 6 年前

干得好,应该有一个带有RXJS 6.x的ES6版本:

import { interval } from 'rxjs';
import { take, map } from 'rxjs/operators';

const array = [2, 3, 4, 5, 6];
interval(2000)
  .pipe(take(array.length))
  .pipe(map(i => array[i]))
  .subscribe(
    val => console.log(val)
  );

推荐文章

Anjil Dhamala · 在收到特定http状态时重试http调用

7 年前

simonberry · 取消RXJS FlatMap链上的订阅

7 年前

user9487981 · 可以激活防护装置并使用角度为5的可见光

7 年前

makat · 角度5 HTTP请求间隔使用可观察值,而值可能会更改

7 年前

Gissipi_453 · 在RxJava 2中的可观察对象中发出字符串数组时出现“不兼容类型”错误

7 年前

Jake Shakesworth · 如何将一个可观察对象映射到另一个可观察对象

7 年前

Nomura Nori · 许诺仅当使用了4个以上的承诺时,才获得“Access Control Allow Origin”

7 年前

MindlessRouse · 路由解析程序在没有订阅的情况下不触发可观察

7 年前

DevMike · 在角度服务中,如果在可观测范围内使用贴图功能,那么假设贴图功能保证同步是否正确?

7 年前

Arun Prasad E S · 角度5,离子3-【ts】类型“void”不可分配给类型“Observable<Post[]>”

7 年前