创建一个Observable对象:
var observable = (function (observer) {
observer.next(1);
observer.next(2);
observer.next(3);
setTimeout(() => {
observer.next(4);
();
}, 1000);
});
订阅获取数据
console.log('just before 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');
实例
function getData(param){
return (observer => {
this.(ParamsConfig.SERVER_URL, JSON.stringify(param), options)
.subscribe(res => {
var svc = (<ParamsData>()).svcCont;
if ( == "9") {
("OthLoginPage");
} else {
(svc);
}
},error2 => {
(error2)
})
}, err => {
(err)
});
}
取值:
this.getData(params).subscribe({
next: x => console.log('got value ' + x),
error: err => console.error('something wrong occurred: ' + err),
complete: () => console.log('done'),
});