RxJS 订阅者取消订阅与完成

Question

我通读了RxJS文档，并希望确保我理解了< code > subscriber . unsubscribe()和< code > subscriber . complete()之间的区别。

假设我有一个有两个订阅者的可观察对象，订阅者1和订阅者2。如果订阅者1对其订阅调用取消订阅，它将不再接收来自可观察对象的通知，但订阅者2将继续接收它们。

<代码>的文档。complete():

观察者回调，用于从可观察对象接收类型完整的无值通知。通知观察者观察对象已完成基于推送的通知的发送。

这是否意味着在上面的相同场景中，订阅者1可以调用完成，它将结束可观察的并停止订阅者1和订阅者2的流？

Answer 1

根据我使用API的经验，我的想法是：你不需要调用Observable，Observatable会调用你。如果您创建Subject，然后下一个/完成Subject，您就可以触发事件。

这就是为什么您将看到一些示例，这些示例将“私有”主体作为类成员，但公开的项目是可观察对象。期望您将订阅 Observable，顶级类将使用 next（） 和 error（） 通过 Subject 调度值。完成可观察量/主题的唯一方法是完成（）主题。

此外，订阅者没有un的（）方法，订阅有。

Answer 2

订阅者不调用 complete（）。您可以在主题上调用 complete（），或者更典型的是使用 take（）、takeWhile（）、...

例如：

const s = new Subject();
const subscriber1 = s.subscribe(...);
const subscriber2 = s.subscribe(...);
s.complete(); // both subscribers will receive the complete notification

// or with `take(1)` operator it'll call `complete()` for you
const subscriber1 = s.take(1).subscribe(...);
const subscriber2 = s.take(1).subscribe(...);
s.next(42); // both subscribers will receive the complete notification

请注意，在主体上调用 complete（） 会更改其内部状态，并且无法使其再次不完整，而只是取消订阅订阅者对主体没有影响。

有点类似的问题:最终在订阅上可以观察到