여러 FirebaseListObservables 결합하기

Question

const placeId = this.getPlaceId(); 
     this.af.database.list(`placeUsers/${placeId}`).subscribe((userKeys) => { 
      for (let index = 0; index < userKeys.length; index++) { 
       let userKey = userKeys[index]; 

       this.af.database.list(`userDevices/${userKey.$key}`).subscribe((deviceKeys) => { 

        for (let index = 0; index < deviceKeys.length; index++) { 
         let deviceKey = deviceKeys[index]; 

         this.af.database.object(`devices/${deviceKey.$key}`).subscribe((device) => { 

          console.log(device); 
          // Device received.  

         }); 
        } 
       }); 
      } 
     }); 

현재 장소를 팔로우하는 모든 사용자에게 알림을 보내려합니다.

• (userDevices 노드)
• deviceKeys에서 장치를 얻기 (placeUsers 노드)
• 사용자에 속하는 deviceKeys 얻기 장소에 속한 사용자 얻기 (: 전류의 흐름은 다음과 같이 진행 devices 노드)

이러한 모든 호출을 하나의 관찰 가능한 호출로 결합하는 방법이 있는지 궁금합니다.

현재 나의 문제점은 이러한 모든 요청이 언제 완료되었는지를 알 수 없다는 것입니다. RxJ를 살펴 봤는데,이 모든 관측 자료를 결합 할 수 있습니다. 그러나 나는 4 개의 노드로 그것을하는 방법에 대한 좋은 해결책을 찾지 못했습니다.

Answer 1

concatMap 및 forkJoin을 사용하여 장치를 방출하는 관찰 가능 항목을 구성 할 수 있습니다. 관찰로 구성된이 장치의 단일 배열을 방출 할 것이다 것입니다 다음 완료합니다 (first 연산자는 첫 번째 방출 목록 또는 개체 걸릴 사용되는) :

import { Observable } from 'rxjs/Observable'; 
import 'rxjs/add/operator/concatMap'; 
import 'rxjs/add/operator/first'; 
import 'rxjs/add/operator/forkJoin'; 

this.af.database 
    .list(`placeUsers/${placeId}`) 
    .first() 
    .concatMap(userKeys => { 
    let observables = userKeys.map(userKey => this.af.database 
     .list(`userDevices/${userKey.$key}`) 
     .first() 
    ); 
    return observables.length ? 
     Observable.forkJoin(...observables, (...lists) => [].concat(...lists)) : 
     Observable.of([]) 
    }) 
    .concatMap(deviceKeys => { 
    let observables = deviceKeys.map(deviceKeys => this.af.database 
     .object(`devices/${deviceKey.$key}`) 
     .first() 
    ); 
    return observables.length ? 
     Observable.forkJoin(...observables) : 
     Observable.of([]) 
    }) 
    .subscribe(devices => console.log(devices)); 

당신이 완전하고를 방출하지 않는 것을 관측을 원하는 경우를

import { Observable } from 'rxjs/Observable'; 
import 'rxjs/add/operator/combineLatest'; 
import 'rxjs/add/operator/switchMap'; 

this.af.database 
    .list(`placeUsers/${placeId}`) 
    .switchMap(userKeys => { 
    let observables = userKeys.map(userKey => this.af.database 
     .list(`userDevices/${userKey.$key}`) 
    ); 
    return observables.length ? 
     Observable.combineLatest(...observables, (...lists) => [].concat(...lists)) : 
     Observable.of([]) 
    }) 
    .switchMap(deviceKeys => { 
    let observables = deviceKeys.map(deviceKeys => this.af.database 
     .object(`devices/${deviceKey.$key}`) 
    ); 
    return observables.length ? 
     Observable.combineLatest(...observables) : 
     Observable.of([]) 
    }) 
    .subscribe(devices => console.log(devices));