Gas*_*rr. 3 javascript subscriber observable angular
我正在尝试在 Angular 2 中为我的服务使用 observable。
但我收到此错误:
Uncaught TypeError: Cannot read property 'isStopped' of undefined
Run Code Online (Sandbox Code Playgroud)
我的服务先睹为快:
import { Observable } from 'rxjs/Observable';
import { Injectable } from '@angular/core';
@Injectable()
export class Service{
getList(){
return new Observable((observer)=>{
observer.next(result);
})
}
}
Run Code Online (Sandbox Code Playgroud)
和实施:
import ...
@Component({...})
export class List implements OnInit {
list : any[];
list$ : Observable<Array<any>>;
constructor(...){
}
ngOnInit(){
this.list$ = this.Service.getList();
this.list$.subscribe(
(items) => {
this.list = items;
console.log("triggered");
},
(error)=>{
console.error(error);
},
()=>{
console.log("completed");
}
);
}
}
Run Code Online (Sandbox Code Playgroud)
有没有人有这个错误?我找不到任何相关的东西。
================================================== ==============
编辑:
抱歉,这是“isStopped”的来源:https : //github.com/ReactiveX/rxjs/blob/master/src/Subscriber.ts#L94
来自 rxjs 库。
为了更清楚地说明这个问题,我提供了一个 JSFiddle来演示和解释这个问题。
以下将抛出错误:
未捕获的类型错误:无法读取未定义的属性“isStopped”。
somePromise
.then(result => {
subscriber.next(result);
subscriber.complete();
})
.catch(subscriber.error);
Run Code Online (Sandbox Code Playgroud)
要保留subscriber.error订阅者对象的方法所期望的正确范围,您必须创建一个匿名函数:
somePromise
.then(result => {
subscriber.next(result);
subscriber.complete();
})
.catch((error) => subscriber.error(error));
Run Code Online (Sandbox Code Playgroud)
这个 JS Fiddle 的 JS 部分演示了一个 Typescript 示例。
| 归档时间: |
|
| 查看次数: |
3856 次 |
| 最近记录: |