RXJS erneut auszuführen beobachtbaren nach ersten

Question

beendet hat habe ich eine Funktion in einem Dienst wie diese (Newel):

songs.service.ts

import {Injectable, Inject} from '@angular/core'; 
import {HttpModule, Headers, Http, Response } from '@angular/http'; 
import 'rxjs/Rx'; 

export class SongsService { 

newAlbum(name:string){ 
    name = name.replace(/ /g, '+'); 
    var albumID= ''; 
    return this.http. 
    get(uri + name) 
    .map(
    (res:Response) => {  
     var rawData = res.json();  
     // console.log(rawData); 
     var albumName:string = rawData.data[0].title; 
     albumID = rawData.data[0].id; 
     this.albumSongs(albumID).subscribe(
      songs => { 
      this.newSongs = songs 
      this.albumData = { 
       name:this.newAlbumName, 
       songs:this.newSongs 
      }; 
      this.testalbums.push(this.albumData); 
      } 
     ); 

     // this.albums.push(albumName,this.albumSongs(albumID)) 
    return [albumName, albumID] 
    } 
    ); 
    } 

    newEL (albumName){ 
    return this.newAlbum(albumName) 
    .map(
     album => { 
      return this.newAlbumName = album[0]; 
     } 
    ); 
    } 
} 

newEL() ein Objekt erstellt und schiebt es zu einer array.I wollen diese Funktion in einer anderen Komponente laufen, wenn es beginnt, ich meine so etwas wie dies für async willen

ngOnInit(){ 
    this.songsService.newEl("sams town"); 
    this.songsService.newEl("Blink182"); 
    this.songsService.newEl("enema of the"); 
} 

So tun kann alabels.component sieht so aus, scheint aber nicht zu dem Zeitpunkt fertig zu sein, an dem der nächste beginnt. Wenn ich das gedrückte Array protokolliere, bekomme ich das zweite Element wiederholt. Meine Vermutung ist, dass die zweite Funktion aufgerufen wird, bevor zuerst ein Wert zurückgegeben wird.

AlbenKomponente.

export class AlbumsComponent { 
    ngOnInit() { 
     this.songsService.newEl("sams town").subscribe(
     album => 
      this.songsService.newEl("Madona").subscribe(
       album => { 
        this.songsService.newEl("enema of the").subscribe(
         album => { 
          this.albums = this.songsService.testalbums; 
          console.log(this.albums) 
          // return this.albums = this.songsService.testalbums; 

         } 
        ) 
       } 
      ) 
     } 
    ); 
} 

Jede Idee, wie Sie die Funktionen, um sicherzustellen, werden für die nächste zu beginnen laufen?

Answer 1

Sie können forkJoin oder switchMap verwenden, um eine Abhängigkeit zwischen den im eckigen Service verwendeten Observablen zu erstellen. Andernfalls können Sie eine Kette von Versprechen mit Abhängigkeit in einer primitiven Weise erstellen.

siehe den Link unten

https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/forkjoin.md

und diese Antwort zu

handling observables when one is dependent on data from another