在 RxJS 中，为什么每次订阅都会执行一次管道？

Question

我希望有多个订阅来对可观察的事件做出反应，但我也想记录该事件，因此我通过一个 do() 操作符将其通过管道进行记录。

问题是，我创建的每个订阅都会记录一次事件！

目前我正在通过创建一个Subject 并从事件回调中调用next 来解决这个问题，这允许我记录一次事件并触发多个订阅。

以下是一些演示该问题的代码：https://stackblitz.com/edit/rxjs-xerurd

我觉得我错过了一些东西，难道没有更“RxJS”的方式来做到这一点吗？

编辑：

我并不是要区分 hot 和 cold observable，实际上我使用的是 hot observable - 由fromEvent() 创建的那个，我想知道为什么我的可能很热的事件源表现得像冷的一样。

我现在意识到 - 在阅读了 share() 之后 - pipe() “转变”了你的可观察到的冷，即根据你的来源返回一个冷的（可能是冷的，可能是热的）

Answer 1

因为默认情况下可观察序列是冷的，所以每个订阅都会有一组单独的站点效果。

如果您希望副作用只执行一次 - 您可以通过将单个订阅广播给多个订阅者来共享订阅。为此，您可以使用share、shareReplay 等。

为了更好地理解它的工作原理，什么是“冷”和发布，请参阅 RxJS v4 文档：

4.8 Use the publish operator to share side-effects

Answer 2

编辑：share() 终于开始工作了。请看下面的cmets。感谢@Oles Savluk。

我把我的答案记录在下面。它可能会有所帮助。

---

share() 和多播的东西并没有解决我非常相似的问题。

我是这样解决的：https://stackblitz.com/edit/rxjs-dhzisp

const finalSource = new Subject();
fromEvent(button3, "click").pipe(
  tap(() => {
    console.log("this happens only once")
  }) 
).subscribe(() => finalSource.next())

finalSource.subscribe(
  () => console.log("first final subscription")
)

finalSource.subscribe(
  () => console.log("second final subscription")
)

finalSource.subscribe(
  () => console.log("third final subscription")
)