ein Array/Objekt zurück, statt eines beobachtbaren mit RXJS Karte

Question

Ich habe den folgenden Code, die für jedes Element Schlüssel eine beobachtbare mit den Artikeldetails zurück:

this.list = this.af.database.list("API_URL") 
     .map((ItemKeys) => { 
     return ItemKeys.map((ItemKey) => { 
      return this.af.database.object(API_URL + "/" + ItemKey); //I need this as the object (not observable) 
     }); 
     }).subscribe((items) => { 
     this.lineData = items; //A list of observables 
     }); 

Der Code jedes Element Schlüssel itereates über und wird die Artikeldaten von einem anderen Endpunkt. Das Problem ist, dass es eine beobachtbare Objektdaten zurückholt, und ich brauche es in einem Objekt (das beobachtbare Ergebnis).

Ich habe versucht, das Abonnement Ergebnis mit dem folgenden Code zurück, aber dann alle meine Artikel Daten sind leer (undefined):

this.list = this.af.database.list("API_URL") 
     .map((ItemKeys) => { 
     return orderItemKeys.map((ItemKey) => { 
      this.af.database.object("API_URL" + "/ItemKey.$key) // So I tried to subscribe to this.. 
      .subscribe((data) => { 
      return data; 
      }); 
     }); 
     }).subscribe((items) => { 
     this.lineData = items; // A list with undefined items 
     }); 

Wie ich das Element Datenobjekt als Objekt zurückgeben kann und nicht als beobachtbare von einem Objekt in meinem Fall?

Answer 1

Sie sollten map durch die flatMap ersetzen, da es in der Lage ist Observable<Observable<T>> zu glätten.

var responseStream = requestStream 
    .flatMap(function(requestUrl) { 
     return Rx.Observable.fromPromise(jQuery.getJSON(requestUrl)); 
}); 

responseStream.subscribe(() => {}); 

Der Versuch, den Code zu diesem Grundsätzlich

const databaseList =() => Rx.Observable.from(['a6b54x4', '1e23sa4q']); 
const databaseObject = (id) => Rx.Observable.of({ id, status: 'ok' }) 

databaseList() 
    .flatMap(x => databaseObject(`id/${x}`)) 
    .reduce((x, y) => x.concat(y), []) 
    .subscribe(console.log); 

anzupassen und zu vereinfachen, flacht es Observable<Observable<T>> noch und dann Reduktion mit verschmilzt alles zu einer Ergebnismatrix.

https://jsfiddle.net/6pLpo3cp/

Answer 2

Sie ein Abonnement nicht zurück (von subscribe) innerhalb eines Bedieners. Das ist wahrscheinlich nicht, was du vorhast.

Für den inneren Teil, wo Sie eine Liste von Objekten abrufen, sollten Sie in der Lage sein, ein Array von Observablen aus Array#map() in eine höherwertige Observable mit Observable#from() zu verwandeln. Sie benötigen mergeAll(), um diese Serie von Observablen zurück zu einem einzigen Stream zu bringen, und dann alle ausgegebenen Elemente in einem Array mit toArray() zu sammeln. Dann extrahieren Sie die letzte beobachtbare mit mergeMap().

this.list = this.af.database.list("API_URL") 
    .mergeMap((ItemKeys) => { 
    return Observable.from(ItemKeys.map((ItemKey) => { 
     return this.af.database.object(API_URL + "/" + ItemKey); 
    })).mergeAll().toArray(); 
    }) 
    .subscribe((items) => { 
    this.lineData = items; 
    });