之间的区别。取消订阅。拍(1)

Question

我想知道，在订阅后立即使用取消订阅时，使用 .take（1） 和 .取消订阅之间的性能是否有任何差异：

var observable = Rx.Observable.interval(100);

第一：

var subscription = observable.subscribe(function(value) {
   console.log(value);
}).unsubscribe();

第二：

js prettyprint-override">var subscription = observable.take(1).subscribe(function(value) {
    console.log(value);
});

对它有什么想法会让性能有所不同吗？

Answer 1

请记住，当组件被破坏时，take（1）仍然不会取消订阅。无论组件是活动的还是被破坏的，订阅都保持活动状态，直到发出第一个值。所以如果我们在订阅中做一些更疯狂的事情，比如访问DOM — 我们可能会在控制台中出现错误。

https://medium.com/angular-in-depth/the-best-way-to-unsubscribe-rxjs-observable-in-the-angular-applications-d8f9aa42f6a0

Answer 2

每个人都有不同的目的，所以很难比较它们。

一般来说，如果你采取这个来源：

const source = range(1,3);

…并使用subscribe（）紧接着unsubscribe（

source.subscribe(
  console.log,
  undefined, 
  () => console.log('complete')
).unsubscribe();

…那么，即使我们在订阅后立即调用了＜code＞unsubscribe（）＜/code＞，也会发出＜code＞source＜/code〕中的所有值。这是因为代码仍然是严格顺序的（同步的），而源代码是一个冷可观测的。

1
2
3
complete

顺便说一句，尝试添加＜code＞delay（0）＜/code＞运算符，使＜code＞source.pipe（delay（1））.subscribe（…）.unsubscribe）＜/code>。这使得使用实际的＜code＞setTimeout（）＜/cod>调用来异步发送值，因此，在任何＜code＞下一个＜/code＞处理程序之前调用＜code＞unsubscribe。

换句话说，< code>unsubscribe()可以让您随时停止接收值。即使源没有发出任何值(我们也不会收到任何完整的通知)。

使用< code>take()运算符将链限制为仅发出特定数量的值。

source.pipe(
  take(1),
)
.subscribe(
  console.log,
  undefined,
  () => console.log('complete')
);

这只是发出一个值并完成:

1
complete

即使您添加了. un✘（），结果也是一样的。

观看现场演示:https://stackblitz.com/edit/rxjs-tbu5kb

因此，tak（）是一个运算符，而un✘（）是Subscription对象上的一个方法。这两件事通常可以互换，但它们永远不会完全相互替代。

2019年1月：RxJS 6更新