rxjs - rx (rxjs) fromEvent operator 是多播的吗？

Question

热/冷/多播可能会造成混淆。我想我现在已经明白了，但我想确认我理解正确。

Looking at the source for rxjs's implementation for fromEvent ，构造函数调用 .publish().refCount()。这是否意味着我使用 fromEvent 设置的事件监听器，例如 fromEvent(document, 'click') 只会在有订阅者的情况下添加到文档中，一旦我删除了所有订阅者，事件监听器也将被删除？我关心性能并希望将单个源流多播给所有订阅者。我相信我理解正确，但如果我不明白，我会喜欢一些澄清。这似乎应该是默认情况。

谢谢!

Answer 1

这是一个有趣的问题，我从未想过要测试!

说到测试，RxJS 的测试表明监听器仅在订阅时添加，并在没有订阅时移除: http://reactivex.io/rxjs/test-file/spec-js/observables/fromEvent-spec.js.html#lineNumber48

浏览器中的快速测试证实了这一点。在开发工具打开的情况下玩这个片段:

const subs = []

const panel$ = Rx.Observable
  .fromEvent(document.getElementById('target'), 'click')

function add() {
  subs.push(panel$.subscribe(() => console.log('click')))
  console.log('subscribe')
}

function clearEm() {
  subs.forEach(s => s.unsubscribe())
  console.log('unsubscribe')
}

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.5.6/Rx.min.js">
</script>

<button id="target">Target</button>
<br/><br/>
<button onclick="add()">Add</button>
<button onclick="clearEm()">Clear</button>

这是调试器显示的内容，当您右键单击目标按钮并查看其附加事件监听器列表时。您可能需要点击调试器的刷新按钮才能查看最新列表。