新建一个Observable,返回observable对象

时间:2025-03-21 19:07:49

创建一个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'),
});