Angular
RXJS और वेधशाला

कई अनुरोधों की प्रतीक्षा करें

एक सामान्य परिदृश्य जारी रखने से पहले समाप्त करने के लिए कई अनुरोधों की प्रतीक्षा करना है। यह forkJoin विधि का उपयोग करके पूरा किया जा सकता है।

निम्न उदाहरण में, forkJoin दो तरीकों कि वापसी कॉल करने के लिए प्रयोग किया जाता है Observables । जब .subscribe पूरी हो .subscribe तो .subscribe मेथड में निर्दिष्ट कॉलबैक को .subscribe जाएगा। मानकों के द्वारा आपूर्ति की .subscribe करने के लिए कॉल में दिए गए आदेश से मेल .forkJoin । इस स्थिति में, पहले posts फिर tags ।

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

मूल अनुरोध

निम्न उदाहरण एक सरल HTTP GET अनुरोध प्रदर्शित करता है। http.get() एक Observable रिटर्न देता है जिसकी विधि subscribe । यह एक लौटे डेटा को posts सरणी में जोड़ता है।

var posts = []

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