我想取消订阅observable,我是否应该使用first()运算符取消订阅?
以下示例,
Rx.Observable.interval(100)
.do(x => console.log(x))
.first()
.subscribe(x => x);
以上代码是否会自动取消订阅或需要做什么?
first()运算符采用可选的谓词函数,并在源完成时没有值匹配时发出错误通知。
在首先发出任何事件之后,它将取消订阅。所以要回答你的问题,你不需要做任何事情。它将取消订阅。
您提供的示例在提交第一个值后自动取消订阅。请使用以下示例
Rx.Observable.interval(100) .first() .subscribe( x => { console.log(x) }, err => { console.log("error") }, () => { console.log("Completed"); });
通常,first()运算符用于获取序列的第一个值。当我们想要取消订阅时,我不确定我们是否可以在任何地方使用它。