rxjs - 如何延长 rx Observable.timer 的持续时间？

Question

给定一个Observable.timer(10000). 说，我想不断更新计时器并且不允许它发出，这可能吗？

例如，在 t = 2000 时，我想将超时时间增加 2000。鉴于此动态代码更改，计时器现在将在 t = 12000 而不是原来的 t = 10000 时发出。

标签： rxjs

Answer 1

试试下面的代码。

Rx.Observable.fromEvent(document,"click")
.scan((curr,acc)=>++curr,0)
.flatMap(e=>{
console.log(e)
return Rx.Observable.timer(e*1000)}
)
.subscribe(console.log)