【发布时间】:2021-05-01 14:53:20
【问题描述】:
我正在尝试理解 observables RxJs,并且我正在使用 Angular 框架!我无法理解'subscriber function'中实际发生的事情,它有一个名为'observer'的参数,并且这个参数在函数体中有一个方法,它的名字是next()!一个函数参数可以拥有一个方法吗?根据什么规则?! 下一个问题是:“Observable”类发生了什么?我认为订阅者函数返回或更准确地说,创建并将值传递给 Observable 实例!当我们在 'customIntervalObservable' 上调用 subscribe 方法时,它会将该数据或值传递给 subscribe 方法吗? 我说的对吗?
const customIntervalObservable = new Observable(function subscriber(
observer
) {
let count = 0;
setInterval(() => {
count++;
observer.next(+count);
if (count > 3) {
observer.error(new Error("count is greater than 3"));
}
}, 1000);
});
this.firstObjSubs = customIntervalObservable.subscribe(
(data: number) => {
console.log(data);
},
(error) => {
console.log(error), alert(error.message);
}
);
}
ngOnDestroy() {
//this.firstObjSubs.unsubscribe();
this.firstObjSubs.unsubscribe();
}
}
【问题讨论】:
标签: javascript angular rxjs observable