首页 > 解决方案 > 不可订阅的 RxJS 间隔

问题描述

当我在我的 Express.js 服务器应用程序中运行以下 RxJS 片段时,可观察到的时间间隔永远不会停止。

我试图在应用程序外部的单独文件中运行它,它工作得很好。有人可以向我解释一下吗?

interval(1000)
  .pipe(tap(() => console.log('foo')))
  .subscribe({next() { console.log('bar')}})
  .unsubscribe()

结果:

foo
foo
foo
...

预期结果:没有:)

编辑:上面的代码只是为了说明问题而进行的毫无意义的简化。我的原始代码是定期向给定端点发出请求。我发现当我取消订阅 observable 时(一段时间后),请求端点永远不会停止。

标签: expressrxjs

解决方案


推荐阅读