共享的预订阅 RxJS 可观察对象

Question

我有一个可观察对象，我需要它像一个承诺一样行事，即链应该在创建时执行一次并导致热可观察对象。

这是一个例子：

console.log('0 ms');

var foo$ = new Observable(obs => obs.next(1))
.map(v => {
  console.log('map, ' + v);
  return v + 1;
})
.share();

foo$.subscribe(); // would like to skip this

setTimeout(() => {
  console.log('100 ms');
  foo$.subscribe(v => { console.log('subscribe, ' + v); });
});

它会产生理想的输出：

0 毫秒

地图 1

100 毫秒

订阅 2

observable 需要额外订阅subscribe()，我想避免这种情况。

但这不适用于已完成的可观察对象：

console.log('0 ms');

var bar$ = new Observable(1, 2)
.map(v => {
  console.log('map, ' + v);
  return v + 1;
})
.share();

bar$.subscribe(); // would like to skip this

setTimeout(() => {
  console.log('100 ms');
  bar$.subscribe(v => { console.log('subscribe, ' + v); });
});

期望的输出：

0 毫秒

地图 1

地图 2

100 毫秒

订阅 2

订阅 3

实际输出：

0 毫秒

地图，1

地图，2

100 毫秒

地图，1

订阅 2

地图，2

订阅 3

每次订阅都会重新执行可观察链。

以Observable.of 和增量映射为例。 observable 和它的链都可能代价高昂，因此链应该只执行一次，类似于 promise。但我不能只切换到 promise，因为完成的 observable 中可以有多个值。

另一个问题是 Promise 容易受到 GC 的影响，不会导致内存泄漏。我不确定可观察订阅是否可以保证这一点。

如何使用操作员预先订阅 observable 以避免虚拟 subscribe()？

如何预先订阅具有多个值的已完成 observable 并避免多链执行？

可以像 Promise 一样对此类 observable 进行垃圾回收吗？

有类似的已回答问题，但我相信它们并不能解决所有问题。

Answer 1

observable 需要使用额外的 subscribe() 进行订阅，我想避免这种情况。

你不能。订阅是执行一个可观察的周期。这就像说你想调用一个函数myFunc，而不必写括号myFunc()。

有办法“隐藏”这样做，但它们会显着改变正在发生的事情。并且订阅仍然发生，它只是隐藏在运营商中（您仍然必须致电）。例如，您可能必须改为 connect。

如何使用操作符预先订阅 observable 以避免虚拟 subscribe()？

一般来说，您希望多播您的 observable。有很多运算符可以实现这一点，从原始的multicast 到publish、share 以及各种publish* 和share* 变体。它们都做的事情略有不同，所以使用哪一个取决于你想要做什么。

可以像 Promise 一样对此类 observable 进行垃圾回收吗？

如果您妥善管理您的订阅，GC 就没有问题。但您确实需要确保所有订阅都在不再需要时结束。

---

我发现自己无法给出具体的答案来实现您发布的所需输出，因为这对我来说没有意义。由于您将发出的值 (1, 2) 映射到它们的后继值，因此生成的 observable 会发出 2 和 3。我不明白为什么订阅应该只发出 2，而不是 3。