Angular2 - Faire de la chaîne d'async appels de service (requêtes http) dans un composant?

J'ai un composant qui, la première, plus besoin d'appeler un service de POSTER quelque chose. Puis, dans le même composant que je veux attendre jusqu'à ce que le POSTE est fait pour appeler un autre service qui Reçoit les données.

Comment puis-je faire l'OBTENIR de l'appel en attente pour le POSTE d'appel à la fin?

En nouvelle-version.composante.ts:

private createNewVersion(value) {
    ...

    //create new version, then call on all available versions

    //POST call
    this._newVersionService.createNewVersion(vnr);

    //GET call
    this._versionService.getAvailableVersions(); 

    ...
}

En nouvelle-version.service.ts:

export class NewVersionService {

response$: Subject<any>;

constructor(private _http: Http) {
    this.response$ = new BehaviorSubject<any>(null);
 }

public createNewVersion(versionNr) {    
    this._http.post('http://localhost:8080/services/' + versionNr, null, {
        method: 'POST',
    })
    .subscribe(response => {
        this.response$.next(response.status);
    },
    error => console.error(error));
}

Merci!

J'ai un exemple de chaîne, appel ici:syntaxsuccess.com/viewarticle/angular-2.0-and-http Mon exemple est un get, mais vous pouvez le changer pour un post

OriginalL'auteur Sojye | 2016-02-03

  1. 5

    Lorsqu'un appel renvoie une Promise de la chaîne d'appels avec 

    someFunction() {
  return returnsPromise()
    .then(result => doSomethingNext())
    .then(result => doSomethingAfterThat());
}

    Vous assurer d'avoir une return qui renvoie la Promise de la chaîne de l'appelant de someFunc() a aussi une chance pour le temps de travail supplémentaire à exécuter après l' doSomethingAfterThat() est terminé.

    Lorsqu'un appel renvoie un Observable puis utilisez le complete rappel

    someFunction() {
  return returnsObservable()
    .subscribe(
      event => doForEachEvent(),
      error => handleError(),
      () => doSomethingNext()
          .then(result => doSomethingAfterThat());
}

    doSomethingNext() est exécutée après la dernière event et doSomethingAfterThat() est de nouveau enchaîné avec then() de montrer comment mélanger observables et de la promesse. doSomething().

    OriginalL'auteur Günter Zöchbauer

  2. 1

    Vous devriez être en mesure de concat pour réaliser la séquence, et reduce pour recueillir les émissions de valeurs:

    var a = this._newVersionService.createNewVersion(vnr);
var b = this._versionService.getAvailableVersions(); 

Rx.Observable.concat(a, b).reduce((acc:Array<any>, x:any) => {
    acc.push(x); return acc;
}, []).subscribe(t=> { 
      var firstEmitted = t[0];
      var secondEmitted = t[1];
});

    OriginalL'auteur pixelbits

  3. 0

    Vous pouvez le faire comme ceci:
    Changement createNewVersion:

    public createNewVersion(versionNr) {
 return this._http.post('http://localhost:8080/nod_inspection_plugin/services/' + versionNr, null, {
    method: 'POST',
 });
}

    Puis dans votre appel:

    this._newVersionService.createNewVersion(vnr).subscribe(response=> {
 this._versionService.getAvailableVersions(); 
}, error => console.error(error));

    OriginalL'auteur Vlado Tesanovic

  4. 0

    Une autre façon de faire de même est-à - subscribe dans le new-version.component.ts et de vous appeler GET demande à partir de l'intérieur de la POST demande, je.e vérifiez si votre POST demande est effectuée Correctement ou pas
    si oui POST est fait Correctement, alors vous appeler GET demande. Comme ci-dessous:

    En nouvelle-version.composante.ts:

     private createNewVersion(value) {
    ...
    //create new version, then call on all available versions

    //POST call
    this._newVersionService.createNewVersion(vnr)
        .subscribe((res) => {
            if(res){
                console.log(res);
                if (---Post request done properly check via status or something else here----{
                    CALL YOUR GET REQUEST HERE.....
                    //GET call 
                    this._versionService.getAvailableVersions(); 
                }
                else {
                    DO something else whatever you want....
                }
            }
        });
    ...
}

    En nouvelle-version.service.ts:

    export class NewVersionService {

response$: Subject<any>;

constructor(private _http: Http) {
    this.response$ = new BehaviorSubject<any>(null);
 }

public createNewVersion(versionNr) {    
    this._http.post('http://localhost:8080/nod_inspection_plugin/services/' + versionNr, null, {
        method: 'POST',
    })
    .map(response => {
        return [{status: response.status, json: response.json()}];
    },
    error => console.error(error));
}

    pour plus d'informations liées à la http demande, vous pouvez lire ici.

    pourquoi downvote ??
    Avez-vous jamais lu de votre propre code? Votre code est illisible. C'est probablement la raison

    OriginalL'auteur Pardeep Jain

  5. 0

    Mieux utiliser switchMap() ici.

    const versions$ = this._newVersionService.createNewVersion(vnr)
                 .switchMap(response => this._versionService.getAvailableVersions());

versions$.subscribe(response2 => this.versions = response2)

    Mais le problème va être si vous faites un autre POST demande avant la première a été résolu, la demande sera annulée.

    OriginalL'auteur ritz078