Warten auf eine Observable zu beenden

Question

Ich habe eine Methode, die auf eine Observable warten muss, um zu beenden. Ich weiß, beobachtbar sind großartig für die Rückgabe einzelner Daten im Laufe der Zeit, aber ich muss wissen, wann dieses Observable vollständig fertig ist, alle seine Daten zurückgeben, damit ich Validierungscode auf das Objekt, das es zurückgegeben hat, ausführen kann.

Die Methode getCustom abonniert einen beobachtbaren Lauf auf der gelieferten URL, der das Observable zurückgibt.

Ich bin mir nicht sicher, ob dies der beste Weg ist, um diese Situation anzugehen, also würde ich mich freuen, wenn mir jemand einen Rat oder eine Anweisung geben könnte, damit umzugehen.

private validateQuoteRetrievalAnswers(reference: string) { 

     // Get the risk from the server 
     this.riskManager.getRiskFromServer(reference); 

     if (this.riskManager.risk) { 
      // Validate risk that was returned 
     } 
    } 

getRiskFromServer(quoteReference: string) { 

    this.riskService.getCustom("Url").subscribe => { 
     // need to know when the observable has returned the risk 
    }); 

} 

Answer 1

, wie ich diese Herausforderung angehen würde:

Abfrage Sie Back-End und als wir haben, was wir schieben müssen sie an einen Gegenstand

riskSubject = new Subject<Risk>(); 

getRiskFromServer(quoteReference: string) { 
    this.riskService.getCustom("Url") 
    .subscribe( 
    data => { this.riskSubject.next(data); }, 
    error => { console.log(error) } 
}); 
} 

und abonnieren dann zu unterwerfen und zu warten, bis Sie das bekommen, was Sie brauchen, und mit der Validierung beginnen

private validateQuoteRetrievalAnswers(reference: string) { 

     // Get the risk from the server 
     this.riskManager.getRiskFromServer(reference); 
     // subscribe to subject 
     this.riskManager.riskSubject.subscribe(
     data => { 
      //do your validation 
     }) 
} 

Das Herz eines beobachtbaren Datendienstes ist das RxJs-Thema. Die Subjekte implementieren sowohl die Observer- als auch die Observable-Schnittstelle, was bedeutet, dass wir sie sowohl zum Ausgeben von Werten als auch zum Registrieren von Subskripten verwenden können.

Das Thema ist nichts anderes als ein traditioneller Event-Bus, aber viel leistungsfähiger, da es alle funktionalen Operatoren von RxJs damit versorgt. Aber in ihrem Herzen, wir es einfach verwenden wie eine normale beobachtbaren

Quelle abonnieren: angular-university.io

OR können Sie benutzen Observable.fromPromise (Versprechen), aber das wird ein wenig komplizierter zu machen, Dinge zu verstehen Wenn Sie neu bei ng2 sind