Angular 6:如何识别forkJoin响应

tt0*_*206 4 rxjs angular

Angular 6:如何用forkJoin识别api的响应

reqs = [];
if (shouldUpdatePhone) {
   reqs.push(this.customerService.updatePhone(phoneUpdateRequest))
}
if (shouldUpdateAddress) {
   reqs.push(this.customerService.updateAddress(addressUpdateRequest))
}

forkJoin(reqs).subscribe(result => {
   console.log('result :', result);
  //How to know response is from updatePhone and response from updateAddress?
});
Run Code Online (Sandbox Code Playgroud)

如何识别收到的响应属于updatePhone和updateAddress?基于身份识别我需要向用户显示消息.

这两个api返回 Array(2)>

{model:true,code:200,message:null},

{model:true,code:200,message:null}

ggr*_*nig 7

您可以map在每个请求后使用管道将您的响应包装在另一个标识其类型的对象中.像这样:

reqs = [];
if (shouldUpdatePhone) {
    reqs.push(this.customerService.updatePhone(phoneUpdateRequest)
        .pipe(map(value => ({type: 'phone', value: value})))
        .pipe(catchError(value => of({type: 'phone', failed: true}))))
}
if (shouldUpdateAddress) {
    reqs.push(this.customerService.updateAddress(addressUpdateRequest)
        .pipe(map(value => ({type: 'address', value: value})))
        .pipe(catchError(value => of({type: 'address', failed: true}))))
}

forkJoin(reqs).subscribe(results => {
    console.log('result :', results);

    for(let result of results){
        if(result.type == 'phone'){
            if(result.failed)
                console.log("Phone failed");
            else
                console.log("Phone: " + result.value);
        }

        else if(result.type == 'address'){
            if(result.failed)
                console.log("Address failed");
            else
                console.log("Address: " + result.value);
        }
    }
});
Run Code Online (Sandbox Code Playgroud)

  • @ggradnig,但事实并非如此,多个订阅不会造成问题......不会陷入冗长的辩论。这是一个例子,只是表明没有必要https://stackblitz.com/edit/angular-axrbvf?file=src%2Fapp%2Fapp.component.ts (2认同)