2017-05-03 74 views

回答

1

Angular使用RxJs库来发送事件。您需要创建回调的Observable。

创建一个新的Observable,当Observer订阅它时将执行指定的函数。

http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#static-method-create

const API= { 
    onResourceStop: 
    { 
     connect(fn) { 
     setTimeout(()=> fn('connect'), 5000); 
     } 
    } 
    }; 

    let observable = Rx.Observable.create(observer => { 
    API.onResourceStop.connect(arg=>{ 
     observer.next(arg); 
     observer.complete(); 
    }); 
    }); 
    observable.subscribe(
    value => console.log(value), 
    err => {}, 
    () => console.log('this is the end') 
);