Как получить реальное значение наблюдаемой - PullRequest
Новая
       6

Как получить реальное значение наблюдаемой

0 голосов
/ 07 сентября 2018

В классе обслуживания метод должен передавать текущее устройство serialNumber. Используя ngrx, устройство $ может быть подписано, чтобы получить реальное, но это не очень хорошо. Что является лучшей практикой в ​​этой ситуации? 

@Injectable()
export class DeviceService {
  public device$: Observable<Device>;
  public device: Device; // feels 'redundant'

  constructor(private http: HttpClient,
              private store: Store<DeviceState>,) {
    this.device$ = this.store.select(DeviceSelectors.getCurrentDevice);
    this.device$.subscribe((device: Device) => {
      this.device = device; // feels bad
    });
  }

  regenerate() : Observable<Object> {
    if (environment.production) {
      const url = `${environment.url}/devices/${this.device.serialNumber}/regenerate`;
      return this.http.get(url) as Observable<Object>;
    } else {
      return of({});
    }
  }
}

Ответы [ 2 ]

0 голосов
/ 07 сентября 2018

@ NielsSteenbeek, Обычно я получаю значение из магазина на лету (при вызове регенерации ()) вы можете использовать flatMap для архивирования того, что вы хотите 

@Injectable()
export class DeviceService {
    constructor(private http: HttpClient, private store: Store<DeviceState>,) {}

    regenerate() : Observable<Object> {
        if (environment.production) {
            return this.store.select(DeviceSelectors.getCurrentDevice)
                .pipe(
                    first(),
                    flatMap(device => this.http.get(`${environment.url}/devices/${device.serialNumber}/regenerate`))
                );
        } else {
            return of({});
        }
    }
}
0 голосов
/ 07 сентября 2018

Вы можете использовать mergeMap для достижения того, что вы хотите: 

@Injectable()
export class DeviceService {
    public device$: Observable<Device>;

    constructor(private http: HttpClient,
                private store: Store<DeviceState>,) {
        this.device$ = this.store.select(DeviceSelectors.getCurrentDevice);
    }

    regenerate() : Observable<Object> {
        if (environment.production) {
            return this.device$
                .pipe(
                    first(),
                    mergeMap(device => this.http.get(`${environment.url}/devices/${device.serialNumber}/regenerate`))
                );
        } else {
            return of({});
        }
    }
}
...