8
Próbuję przechowywać dane w pamięci lokalnej przy użyciu wielu połączeń http. Używam forkJoin, aby poczekać, aż wszystkie połączenia zostały zakończone, a następnie chcę wznowić mój łańcuch połączeń Promise.then
. Jak mam to zrobic?Konwersja RxJS Observable do obietnicy
updateCache() {
var cachesToUpdate;
return this.fetchServerTimestamps()
.then(res => {
var localTimestamps = this.getLocalTimestamps();
var serverTimestamps = this.getServerTimestamps();
//Compare timestamps and decide which cache data types to update
cachesToUpdate = this.cacheTypes.filter(function (cacheType) {
return localTimestamps ? localTimestamps[cacheType.timestamp] != serverTimestamps[cacheType.timestamp] : true;
});
}).then(res => {
//Request data and insert into cache
this.fetchData(cachesToUpdate)
.subscribe(res => {
res.forEach(function (item, index) {
this.insert(cachesToUpdate[index].messageType, JSON.stringify(item));
}.bind(this));
});
});
}
fetchData(cachesToUpdate): Observable<any> {
return forkJoin(cachesToUpdate.map(i => this.callservice.serverRead({ path: 'api/' + i.messageType })));
}
insert(key: string, value: string, compress = true) {
localStorage.setItem(key, compress ? LZString.compress(value) : value);
}
Nie zapomnij o zaimportowaniu "rxjs/add/operator/toPromise"; ' –