ForkJoin Observables от http.get - PullRequest
Новая
       39

ForkJoin Observables от http.get

0 голосов
/ 10 декабря 2018

Я получаю различные очки со временем, когда я получаю много http.get звонков.Мне нужно поместить их все в массив и распечатать в сетке:

Вот как я это делаю:

, когда пользователь вводит interval: 

ngOnChanges() {
if (this.interval) {

  for (let id of this.ids) {
    this.loadData(id);
  }
}
this.initializeCols();

}

Я вызываю loadData(id); метод, который использует ForkJoin для создания данных: 

  private loadData(id: string) {
let url = DataService.url+ '/data/' + id + '/points';

// Generate API requests
let observables = [];
observables.push(this.http.get(url, DataService.contentTypeJsonHeaders).map(r => r.json()));

// const myPromise = val =>
// new Promise(resolve =>
//   setTimeout(() => resolve(`Promise Resolved: ${val}`), 10000)
// );

// of(observables).pipe(mergeMap(q => forkJoin(...q.map(myPromise)))).subscribe(
//   val => this.model.push(val));

Observable.forkJoin(observables).subscribe((response: any[]) => {
  for (let i = 0; i < response.length; i++) {
    let dataArray: Datapoints[] = ArrayFlattener.Inflate(response[i].data);
    for (let d of dataArray) {
      const temp = {
        id: id,
        time: d.time,
        value: d.value,
        originalTime: d.time,
        originalValue: d.value,
        interval: d.interval,
        metric: DataService.GetById(stream.metricId).name
      };
      this.model.push(temp);
    }
  }
});

}

Но я не могу дождаться, пока modelзаполнить данные полностью, а затем распечатать его в сетке.Я оставил закомментированный код в методе loadData() с другой моей попыткой.Проблема в том, что я не вижу данные модели в сетке, пока я не нажму кнопку «Добавить новый» или что-то еще, чтобы сделать еще один вызов, потому что он должен заполнять сетку только после завершения всех вызовов.Что я делаю не так с моим ForkJoin?

1 Ответ

0 голосов
/ 11 декабря 2018

Вы не должны передавать наблюдаемые как один аргумент массива, а вместо этого несколько аргументов.

Попробуйте использовать spread operator: Observable.forkJoin(...observables)

...