如何異步推送數組元素

Question

我正在尋找一種簡單的方法來每秒異步推送數組元素。此代碼工作正常 - 它發送2和第二55：

Rx.Observable.from([2, 55]) 
    .zip(Rx.Observable.interval(1000), x => x); 

有沒有更簡單的方式做同樣的事情？

謝謝。

Answer 1

如果您使用rxjs v4，則可以使用Rx.Observable.generateWithAbsoluteTime。它基本上是一個具有不同時間的循環。

或者你可以使用interval喜歡這裏：

Rx.Observable.interval(1000).take(yourArray.length).map(index => yourArray[index]) 

我不知道什麼是，如果它是簡單的。

Answer 2

使用指定者（）

Rx.Observable 
    .interval(1000) 
    .take(3) 
    .toArray() 
    .subscribe(x=>console.log(x)) 

Answer 3

看一看combineLatest和withLatestFrom但是這真的取決於你想要做什麼。

順便說一句，在這種情況下使用.zip可能並不理想，因爲.zip發出只有當它具有第N從所有源觀測量項目是你平時不想要的東西。