javascript - 使用 SwitchMap 的 Rxjs 倒计时器

标签 javascript timer rxjs

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/

相关文章:

Javascript 代码在模式关闭时不执行

javascript - 将 jquery 选择器转换为数组

ios - 使用自定义 Timer NSObject 在你的 ios 应用程序中计时事件

Angular 6 - 在不相关的组件之间共享一个对象

javascript - 添加 Loader 直到 STL 图像加载 PHP

javascript - 使用(实验性)代码片段功能从 Google Chrome 控制台命令行运行代码片段?

c# - 应该如何管理在函数范围内声明的定时器的清理?

java - 使用用户指定的计时器更新图形用户界面中的 JPanel 和属性?

exception - RXJS - 捕捉观察者抛出的异常

angular - 在 angular2 组件中导入 rxjs 会出错