RXJS 倒计时计时器突然停止,我发现当未发出可信数据时,它被 switchMap 取消。
如何解决?我需要通过单击按钮来启动计时器。 请找到我的示例的jsbin
const start = Rx.Observable.fromEvent(document.querySelector('#btn'), 'click');
start
.switchMap(() => {
return Rx.Observable.timer(0, 1000)
.takeUntil(Rx.Observable.timer(60000 + 1000))
})
.map((value) => 60000 - value * 1000)
.map(function(i) {
return 'Timer (second): ' + i / 1000;
}).subscribe(function(text) {
var container = document.querySelector('#app');
container.textContent = text;
});
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<meta name="viewport" content="width=device-width">
<title>RxJS 5 Operators</title>
<script src="https://npmcdn.com/@reactivex/rxjs@5.0.0-beta.3/dist/global/Rx.umd.js"></script>
</head>
<body>
<button id='btn'> start </button>
<p id='app'></p>
</body>
</html>
最佳答案
尝试将 takeUntil(...)
更改为 take(...)
来自:
.takeUntil(Rx.Observable.timer(60000 + 1000))
致:
.take(60000 / 1000 + 1)
猜测原因:
如果计时器累积了时间错误,则可以在预期的计时器事件发生之前触发 takeUntil
。
time
[0] 0.000
[1] 1.103
...
[59] 60.234
61.003 <- takeUntil fired
[60] 61.123 <- expected last event lost
关于javascript - 使用 SwitchMap 的 Rxjs 倒计时器,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44026062/