角6:如何识别forkJoin响应

Question

角度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?
});

如何识别接收到的响应属于updatePhone和updateAddress？基于标识，我需要向用户显示消息。

这两个api都返回数组(2) >

{模型:真，代码:200，消息:null}，

{模型:真，代码:200，消息:null}

Answer 1

您可以在每个请求之后使用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);
        }
    }
});

Answer 2

基于RxJS文档

forkJoin将等待所有传递的可观测值完成，然后它将发出一个数组，其中包含相应的可观测值的最后一个值。因此，如果将n可观测值传递给操作符，则结果数组将具有n值，其中第一个值是第一个可观测值发出的最后一个值，第二个值是第二个可观测值发出的最后一个值，依此类推。

因此，您的result值应该是一个数组，第一个值是可观察到的updatePhone(...)响应，第二个值是来自可观察updateAddress(...)的响应。