为什么可连接的 observable 只执行一次

Question

当另一个流执行时，我有一个可连接的可观察对象：

const source1 = Rx.Observable.of([1,2,3,4,5])
  .do(() => console.log('Do Something!'))
  .map(() => "Always connected.")
  .publish();

source1.subscribe((v) => console.log(v));

const connect = () => {
  let c = false;
  return () => {
    if (!c) {
       console.log("Get connected");
       source1.connect();
       c = true;
    }
  }
}


const source2 = Rx.Observable.fromEvent(document, 'click')
   .do(() => console.log("execute!"))
   .do(connect())
   .switchMapTo(source1);

source2.subscribe((v) => console.log(v));

输出

"execute!"
"Get connected"
"Do Something!"
"Always connected."

进一步点击文档source1 将不再订阅，我的问题是，为什么？

Answer 1

您确实遇到过这种情况：Rx.Subject loses events

如果您更新示例的第一部分，您将看到主题收到complete 通知：

const source1 = Rx.Observable.of([1,2,3,4,5])
  .do(() => console.log('Do Something!'), null, () => console.log('source1 complete'))
  .map(() => "Always connected.")
  .publish();

这会将 Subject 标记为已关闭，并且不会进一步重新发送任何值。

有关更多详细信息，请参阅我上面的链接答案。您也可以看看 Ben Leash（RxJS 5 的首席开发人员）的 On The Subject Of Subjects (in RxJS)（段落 Subjects Are Not Reusable）。