为了学习rxjs,我正在尝试使用它。
我的代码:
// RxJS v6+
import { withLatestFrom, map } from 'rxjs/operators';
import { interval } from 'rxjs';
const source = interval(1000);
const example = source.pipe(
map(value => value +1),
map(value => {
if(value === 40) {
finish();
}
else if (value % 5 === 0){
return 'can devide by 5 we did some magic';
}else{
return value;
} })
);
const subscribe = example.subscribe(
val => console.log(val),
error => console.log("Error handled: " , error),
() => console.log('resolved'));
我的想法是运行它40次,然后完成这个observable(也可以是另一个要求,例如查看值是否在10:00时为10(主要目标是使用值进行评估并强制完成))。
我正在寻找替代placeholder finish()的方法,因为finish不存在。如何到达subscribe方法的resolve函数() => console.log('resolved')
?
我找到了How can I complete Observable in RxJS ,但答案是2015年的,我认为现在有当前rxjs版本的答案。