Warm tip: This article is reproduced from stackoverflow.com, please click
angular rxjs

Array of observables angular rxjs

发布于 2020-04-10 16:09:47

I have following code:

export class GetPersonsService {
  url="https://swapi.co/api/people/";
  personsObservables;
  headers: HttpHeaders = new HttpHeaders()
    .set('Accept', 'application/json');
  constructor(private http:HttpClient) { }
  getPerson(personIndex){
    return this.http.get<Person>(`${this.url}${personIndex}`,{headers:this.headers});
  }
  getPersons(){
    for(let i=0;i<10;i++){
      this.personsObservables.push(this.getPerson(i));
    }
    console.log(this.personsObservables);
    return forkJoin(this.personsObservables);
  }
}

and I don't understand why this.personsObservables is undefined because If I invoke getPerson(1) I am getting observable.And the next question how to maintain api if there are 10/100 or more items and I want to detect how many are them.

Questioner
graluc
Viewed
39
StepUp 2020-02-02 03:52

It is necessary:

  • at first to initialize an array of url to avoid undefined error
  • then await API call getPerson(i)`
  • then you can use forkJoin.

So the code should look like this:

const personsObservables = [];

async getPersons(){
    for(let i=0;i<10;i++){
        this.personsObservables.push(await this.getPerson(i));
    }
    console.log(this.personsObservables);
    return forkJoin(this.personsObservables);
}

Let me show an example:

const request1 = this.http.get('https://restcountries.eu/rest/v1/name/india');
const request2 = this.http.get('https://restcountries.eu/rest/v1/name/us');
const request3 = this.http.get('https://restcountries.eu/rest/v1/name/ame');
const request4 = this.http.get('https://restcountries.eu/rest/v1/name/ja');

const requestArray = [];
requestArray.push(request1);
requestArray.push(request2);
requestArray.push(request3);
requestArray.push(request4);

forkJoin(requestArray).subscribe(results => {
  console.log(results);
  this.response = results;
});

All results are ordered accordingly pushed items into requestArray. It can be seen in a stackblitz example.