2017-05-03 22 views

答えて

1

Angularは、RxJsライブラリを使用してイベントを送信します。コールバックオブザーバブルを作成する必要があります。

オブザーバーがサブスクライブするときに、指定された機能を実行する新しいオブザーバブルを作成します。

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') 
);