2016-08-31 9 views
1

私はSQLiteデータベースにキャッシュを作るアルゴリズムを持っています。 APIのすべてのエンドポイントを呼び出し、ローカルデータベースに保存します。私はそれがすべて終了したときを知る必要があります。角度1では、要求プールが終了したときにコールバックを呼び出すPromise Queueがあります。イオン2 /角度2ではどのようにして達成できますか?イオン2:HTTPリクエスト "プール"とコールバック

ありがとうございました。

答えて

2

あなたは(活字体で)そのためrxjs、例を使用する必要があります(subscribeが呼び出されたとき)mergeへの呼び出しを同時に実行するすべての要求が発生します

const apiCalls = [ 
    http.post(apiUrl1, arguments1, ...), 
    http.post(apiUrl2, arguments2, ...), 
    http.post(apiUrl3, arguments3, ...), 
    ... 
]; 

Observable.merge(...apiCalls).subscribe(undefined,undefined,() => myOnComplete()); 

subscribeは、3つのコールバック関数、onNext(各放出項目に対して呼び出される)、onError(エラーが発生したときに呼び出される)、およびobservableが正常終了したときに呼び出されるonCompleteを受け入れます。

http://reactivex.io/documentation/operators/merge.html

関連する問題