RxJs: как отправить запрос с новыми данными?

Question

[Millerish]

Доброе время суток!

У меня есть такой код:

contractState = this.http.get(this.apiGetAddressData.getValue().href).pipe(
    repeatWhen(() => this.contractRefresh$),
    switchMap((data: ContractDataModel) => {
      console.log('!!!!!!!!!!!!!!!!!!!!!!!!!!',this.apiGetAddressData.getValue().href, data)
      ...
    }),
    ...

Я изменяю apiGetAddressData и отправляю событие contractRefresh$, но запрос уходит всегда по старому url(хотя console.log показывает новый).

Почему так происходит и как поправить?

Comments

[jamtuson]

this.apiGetAddressData.getValue() - подозреваю, что это оbservable.
Если это так, то надо подписаться на него и только после этого отправлять в get

[Millerish]

jamtuson, this.apiGetAddressData.getValue().href обновляется

[jamtuson]

Millerish, а можешь приложить скрин функции getValue?

[Millerish]

jamtuson, это метод rxjs https://rxjs-dev.firebaseapp.com/api/index/class/B...

Answer 1

[Антон Швец]

ровно наоборот :)

this.contractRefresh$.pipe(
  switchMap(() => this.apiGetAddressData),
  switchMap(addressData => this.http.get(addressData.href)),
  ....
)

однако при такой организации запрос будет выполнен как при эмите this.contractRefresh$, так и при эмите this.apiGetAddressData, что я думаю приемлемо в вашем случае.