Подписка на множественные наблюдаемые

Question

Мне нужно подписаться несколько раз, чтобы получить правильные данные из моей базы данных NoSQL. Для того, чтобы получить список пользователей конкретного проекта, я делаю это:

ngOnInit() { 
    //Subscription 1 (Service): Get project data 
    this.projectService.getCurrentproject().take(1).subscribe(projectData => { 
     console.log('Got project data.'); 
     //Subscription 2: Get project user IDS 
     this.af.database.list('/project_roles/'+projectData.$key) 
      .subscribe((userMeta) => { 
       }); 
      }); 
} 

• Как вы можете видеть, подписку, внутри подписки, внутри подписки .. И каждая подписка зависит от предыдущего одной reslt ,

• Подписки 3 и 4 могут быть параллельными.

код работает хорошо, но я что-то отсутствует или это, как я полагаю, работает с несколькими подписки, что результат предыдущего зависит следующий?

Обновление: Проблема связана с подпиской №2. Подписка еще не завершена, но я начинаю перебирать список, который дает мне двойной список пользователей!

Answer 1

Попробуйте это.

ngOnInit() { 
    this.projectService.getCurrentproject().take(1) 
     .flatMap(projectData => { 
      return this.af.database.list('/project_roles/'+projectData.$key) 
     }) 
     .flatMap(userMeta => { 
      let subs = userMeta.map(projectRole => { 
       return Observable.zip([ 
        this.af.database.object('/roles/'+projectRole.$value), 
        this.af.database.object('/users/'+projectRole.$key) 
       ]).map(([roleData, user]) => { 
        user.role = roleData.$value; 
        return Observable.of(user) 
       }) 
      }); 
      return Observable.zip(subs) 
     }) 
     .subscribe(users => { 
      this.users = users 
     }) 
} 

В основном я сочинял подписки, чтобы получить один наблюдаемым, который излучает пользователям массиву