Angular / RxJS - цепочка двух http get вызовов - PullRequest
Новая
       5

Angular / RxJS - цепочка двух http get вызовов

0 голосов
/ 24 мая 2018

У меня проблема при получении результатов двух http асинхронных вызовов.

Первый маршрут называется /contracts, а второй маршрут /shipments Каждый контракт связан с отправкой, поэтому он имеетshipmentId свойство.Я хочу получить все контракты и для каждого контракта получить соответствующую отправку с моего сервера REST.

Я попытался позвонить и по getContracts(), и по getShipments(), а затем по контракту forEach использовать find в моем shipments[].(результат метода getShipments()), но иногда ответ на вызов отгрузки возвращается после ответа на вызов контракта, и поэтому возвращается ошибка cannot read property x of undefined.

Я пытался использовать также getShipmentById(), но это не гарантируетМне, что все время груз будет возвращен после контракта.

Как это можно сделать с помощью Angular / RxJS?

Вот соответствующие части моего кода: 

  getContracts(): Observable<Contract[]> {
    return this.http.get<Contract[]>(this.contractsUrl)
      .pipe(
        retry(3),
        catchError(this.handleError('getContracts', []))
      );
  }

  getShipments(): Observable<Shipment[]> {
    return this.http.get<Shipment[]>(this.shipmentsUrl)
      .pipe(
        retry(3),
        catchError(this.handleError('getShipments', []))
      );
  }

  getShipmentById(id: string): Observable<Shipment | {}> {
    return this.http.get<Shipment>(`${this.shipmentsUrl}/${id}`)
      .pipe(
        retry(3),
        catchError(this.handleError('getShipmentById'))
      );
  }

1 Ответ

0 голосов
/ 24 мая 2018

forkJoin сделал свое дело.

Спасибо за ответ, я не знал об этой функции.Я выкладываю здесь код, может быть, он поможет кому-то еще с этой проблемой: 

  getContracts(): void {
    forkJoin(
      this.contractService.getContracts(),
      this.shipmentService.getShipments()
    )
      .subscribe(([contracts, shipments]) => {
        if (Array.isArray(contracts) && Array.isArray(shipments)) {
          this.contracts = contracts
            .map(contract => {
              contract.shipment = shipments.find(shipment => shipment.shipmentId === contract.shipmentId);
              return contract;
            });
        }

        console.log(contracts);
      });
  }
...