2017-03-07 55 views
4

下面的代码发出5000msint,然后又在每一个5000ms后:RxJS间隔无延迟

let evens = Observable.interval(5000) 
    .map(i => { 
      return i * 2; 
     }); 

evens.subscribe((i) => { 
     console.log(i); 
}); 

是否有可能做到这一点,但马上有第一个结果(0ms),然后等待5000m之间的后续结果?

回答

9

您可以使用Observable.timer()其中第一个参数是初始延迟:

Observable.timer(0, 5000); 

或者,如果你想发出立即您还可以使用startWith()操作的第一个项目。