Return Versprechen innerhalb Observable

Question

Ich habe eine Angular App mit angularfire2 und ich verwende eine Methode, die einige Informationen aus ein paar verschiedenen Tabellen in Firebase entfernt.

removeTeam(key: string) { 
    const dataToRemove = {}; 
    dataToRemove[`teams/${key}`] = null; 

    this.findMembersInTeam(key).subscribe(members => { 
     members.forEach(member => { 
     dataToRemove[`members/${member}/teams/${key}`] = null; 
     }); 

     this.sdkDB.update(dataToRemove); 
    }); 
    } 

Was dies tut, ist im Grunde zu entfernen/Team/und auch, für jedes Mitglied im Team, um das Team, so entfernen/Mitglieder // Teams /.

Was ich tue, ist die Liste der Mitglieder in einem Team abrufen, und da dies ein beobachtbar ist, innerhalb der abonniere ich komponieren die „Abfrage“ und führen Sie es mit this.sdkDB.update(dataToRemove)

Diese letzte Methode gibt ein Versprechen, und das ist, was ich als Ergebnis der Methode removeTeam zurückgeben möchte, gibt es eine Möglichkeit, das zu tun?

Dank

Answer 1

Try this:

import 'rxjs/add/operator/toPromise'; 

// ... 

removeTeam(key: string) { 
    const dataToRemove = {}; 
    dataToRemove[`teams/${key}`] = null; 
    return this.findMembersInTeam(key) 
       .toPromise() 
       .then(members => { 
        members.forEach(member => { 
         dataToRemove[`members/${member}/teams/${key}`] = null; 
        }); 
        return this.sdkDB.update(dataToRemove); 
       }); 
} 

Answer 2

IF sdkDB kehrt ein beobachtbares, importieren rxjs/add/operator/mergeMap und flatMap oder mergeMap verwenden (flatMap ist nur ein Alias ​​von mergeMap) statt subscribe.

Dies kombiniert Ihre beobachtbaren Streams.

removeTeam(key: string) { 
    const dataToRemove = {}; 
    dataToRemove[`teams/${key}`] = null; 

    return this.findMembersInTeam(key) 
     .flatMap(members => { 
      members.forEach(member => { 
       dataToRemove[`members/${member}/teams/${key}`] = null; 
      }); 

      return this.sdkDB.update(dataToRemove); 
     }) 
     .toPromise(); 
    }