angular2 rxjs beobachtbares forkjoin

Question

Ist es möglich, forkjoin http.get-Anforderungen fortzusetzen, selbst wenn eine der Anforderungen fehlschlägt.

Ich freue mich auf eine ähnliche Funktion von $ q.allSettled in angular2.

Siehe Beispiel: http://jsfiddle.net/Zenuka/pHEf9/

angular.module('qAllSettled', []).config(function($provide) { 
    $provide.decorator('$q', function($delegate) { 
    var $q = $delegate; 
    $q.allSettled = function(promises) { 
     return $q.all(promises.map(function(promise) { 
     return promise.then(function(value) { 
      return { state: 'fulfilled', value: value }; 
     }, function(reason) { 
      return { state: 'rejected', reason: reason }; 
     }); 
     })); 
    }; 
    return $q; 
    }); 
}); 

Kab

Answer 1

Verwendet Observable.forkJoin() mehrere gleichzeitige http.get() -Anforderungen zu laufen. Der gesamte Vorgang führt zu einem Fehlerzustand, wenn eine einzelne Anforderung fehlschlägt.

getBooksAndMovies() { 
    return Observable.forkJoin(
     this.http.get('/app/books.json').map((res:Response) => res.json()), 
     this.http.get('/app/movies.json').map((res:Response) => res.json()) 
    ); 

Aber Sie könnten Ihre zusätzliche GET-Anforderung in den Fehler-Handler setzen:

getBooksAndMovies() { 
    Observable.forkJoin(
     this.http.get('/app/books.json').map((res:Response) => res.json()), 
     this.http.get('/app/movies.json').map((res:Response) => res.json()) 
    ).subscribe(
     data => { 
     this.books = data[0] 
     this.movies = data[1] 
     }, 
     err => console.error(err) 
    ); 

Answer 2

Sie könnten den catch Operator für jede beobachtbare nutzen, um die Fehler abzufangen und andere beobachtbare in solchen Fällen zurück. Hier

ist ein Beispiel:

return Observable.forkJoin(
    this.http.get('/some-url') 
     .map((res:Response) => res.json()) 
     .catch(res:Response => Observable.of({}), 
    this.http.get('/some-other-url') 
     .map((res:Response) => res.json()) 
     .catch(res:Response => Observable.of({}), 
);