【发布时间】:2016-11-09 13:55:56
【问题描述】:
在Rxjs中,我知道subscribe方法有一个Observable Execution的三种类型的值:next,error,complete。在subscribe()方法中写箭头函数很容易,但是我遇到了subscribe({})方法某处。所以我不知道它是什么意思。例如:
var observable = Rx.Observable.create(function (observer) {
observer.next(1);
observer.next(2);
observer.next(3);
setTimeout(() => {
observer.next(4);
observer.complete();
}, 1000);
});
console.log('just before subscribe');
observable.subscribe({
next: x => console.log('got value ' + x),
error: err => console.error('something wrong occurred: ' + err),
complete: () => console.log('done'),
});
console.log('just after subscribe');
在本例中,它使用 observable.subscribe({}),以及不同的表达式示例,如下所示:
getHeroes() {
this.heroService.getHeroes()
.subscribe(
heroes => this.heroes = heroes,
error => this.errorMessage = <any>error);
}
【问题讨论】:
-
提供完整的表达式。
-
我已经更新了问题,不知道是否清楚,谢谢您的建议