RxJs Partion if then else

Question

url 매개 변수에 null ID가 없으면 getUserDetails 및 getOrganinztion List를 호출하십시오. url 매개 변수에 id가 없으면 getOrganinztion을 호출하십시오. 그러나 문제는 최신을 결합이다는 내가 일을 할 것입니다 rxjs와 같은

Answer 1

뭔가를이 문제를 모델링하는 방법 시나리오 2.

let [updateUser$, createUser$] = this.route.params 
      .map((params: Params) => params['id']) 
      .partition(id => !!id); 


    updateUser$ = updateUser$ 
     .do(() => { 
     this.isEdit = true; 
     }) 
     .flatMap(id => this.userService.getUserById(id)) 
     .map(user => { 

     let languageId = user['languageId']; 
     let organization = user['organization']; 
     let organizationObj = [{ id: organization, text: organization }]; 
     return Object.assign(user, { languageId: [{ id: languageId, text: languageId }] }, { organization: organizationObj }); 
     }); 


    let getOrganization$ = this.userService.getOrganization(); 


    Observable.combineLatest(getOrganization$, updateUser$, (organizationList: any, user: any) => { 
     return { 
     organizationList: organizationList, 
     user: user 
     }; 
    }) 
     .subscribe((data: any) => { 
     // pre populate the form 
     let user = data.user; 
     if (user) { 
      Object.keys(user).forEach(key => { 
      const control = this.userForm.get(key); 
      if (control) { 
       control.setValue(user[key]); 
       control.markAsDirty(true); 
      } 
      }); 
     } 

     this.organizationList = data.organizationList.map(o => o.name); 

     }, err => this.error(err)); 


    Observable.combineLatest(getOrganization$, createUser$, (organizationList: any) => { 
     return { 
     organizationList: organizationList, 
     }; 
    }) 
     .subscribe((data: any) => { 
     this.organizationList = data.organizationList.map(o => o.name); 
     }, err => this.error(err)); 

에 대한 호출되지 않습니다. 더미 관측 값을 http 및 경로 1로 바꿉니다. 이것은 단지 시뮬레이터입니다.

let routes$ = Rx.Observable.create((observer) => { 
    observer.next({id:1}); 
    setTimeout(()=> observer.next({xx:1}), 1000); 
    setTimeout(()=> observer.next({id:2}), 2000); 
    setTimeout(()=> observer.next({xx:2}), 3000); 
    setTimeout(()=> observer.next({id:3}), 4000); 
}); 

let [updateUser$, createUser$] = 
    routes$ 
    .map(params=> params['id']) 
    .partition(id => !!id); 


updateUser$ 
    .switchMap(id=>Rx.Observable.of(`${id}_user`)) 
    .switchMap(user=>Rx.Observable.of('organizationList'), 
     (user, organizationList) => ({user, organizationList}) 
).subscribe(x=>console.log(x)); 

createUser$ 
    .switchMap(id=>Rx.Observable.of('organizationList')) 
    .map(organizationList=> ({organizationList})) 
    .subscribe(x=>console.log(x));