javascript - 为什么我们要完成observable？

Question

我想知道在下面编写的代码中不编写完整语句的缺点。在这种情况下会发生什么？

Observable.create(function(observer) {
  observer.next('Hello');
  observer.next('World');
  // observer.complete(); 
});

Answer 1

如果您不调用 .complete()，订阅者将永远不会知道您的 Observable 将不再发出事件。通过调用.complete()，所有订阅者将取消订阅并释放分配的内存，从而防止内存泄漏。您可以假设订阅者将自行取消订阅(基于事件内容、事件计数或其他任何内容)，但强烈建议发出“已完成”事件，因为这会阻止您的 Observable 被取消订阅。滥用。

此外，正如注释中所写，如果 Observable 未完成，某些运算符根本无法工作(例如 concatMap 将等待 Observables 完成，然后再切换到下一篇)