Angular
RXJS i obserwowalne

Poczekaj na wiele żądań

Jednym z typowych scenariuszy jest oczekiwanie na zakończenie szeregu żądań przed kontynuowaniem. Można to osiągnąć za pomocą metody forkJoin .

W poniższym przykładzie forkJoin jest używany do wywoływania dwóch metod, które zwracają Observables . .subscribe zwrotne określone w metodzie .subscribe zostanie wywołane, gdy oba obserwowalne zakończą się. Parametry .subscribe przez .subscribe zgodne z kolejnością podaną w wywołaniu do .forkJoin . W takim przypadku najpierw posts a następnie tags .

loadData() : void {
    Observable.forkJoin(
        this.blogApi.getPosts(),
        this.blogApi.getTags()
    ).subscribe((([posts, tags]: [Post[], Tag[]]) => {
        this.posts = posts;
        this.tags = tags;
    }));
}

Podstawowe zapytanie

Poniższy przykład demonstruje proste żądanie HTTP GET. http.get() zwraca wartość Observable która ma metodę subscribe . Ten dołącza zwrócone dane do tablicy posts .

var posts = []

getPosts(http: Http): {
    this.http.get(`https://jsonplaceholder.typicode.com/posts`)
        .subscribe(response => {
            posts.push(response.json());
        });
}