Angular 6: Как определить ответ forkJoin

Question

Angular 6: Как идентифицировать ответ API с помощью forkJoin

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 возвращают Array (2)>

{модель: true, код: 200,сообщение: null},

{модель: true, код: 200, сообщение: null}

Answer 1

Вы могли бы сделать что-то вроде этого:

forkJoin(reqs).subscribe(([phone, address]) => {
   if (!shouldUpdatePhone) {
     address = phone;
   }
});

Но я думаю, что вы что-то наблюдаете, forkJoin выдает массив ответов от всех внутренних наблюдаемых, как только они все завершены.Таким образом, он будет выдавать только один раз, содержащий оба ответа (если они оба были добавлены в массив)

другой вариант - добавить канал в forkJoin и внутренние подпрограммы (непроверенный код):

const reqs = [];
if (shouldUpdatePhone) {
   reqs.push(this.customerService.updatePhone(phoneUpdateRequest)).pipe(
     map((response) => ({ phone: response }))
   );
}
if (shouldUpdateAddress) {
   reqs.push(this.customerService.updateAddress(addressUpdateRequest)).pipe(
     map((response) => ({ address: response }))
   );
}

forkJoin(reqs).pipe(
  map((responses) => reponses.reduce((a, b) => ({...a, ...b}), {}))
).subscribe(result => {
   // result.address;
   // result.phone;
});

Answer 2

На основании документации RxJS :

forkJoin будет ожидать завершения всех переданных наблюдаемых, а затем будет выдавать массив с последними значениями из соответствующих наблюдаемых. Поэтому, если вы передадите n Observables оператору, результирующий массив будет иметь значения n, где first value - это последнее, что испускается первым Observable, второе значение - это последнее, что испускается вторым Observable и т. Д.

Следовательно, ваше значение result должно быть массивом, первое значение которого является ответом наблюдаемой updatePhone(...), а второе значение - ответом наблюдаемой updateAddress(...).

Answer 3

Вы можете обернуть ваши ответы в другой объект, который идентифицирует их тип, используя канал 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);
        }
    }
});