Déclarer une fonction comme Observable

Version imprimable

11/08/2020, 11h47
achem91

Déclarer une fonction comme Observable
Bonjour,

Pour un besoin d'asynchronisme, je voudrais utiliser une fonction comme un observable, je m'explique :

Actuellement j'ai une fonction getDemande(date) qui contient elle même un appel à un autre observable qui me retourne des valeurs :
Code:

1 2 3 4 5 6 7 8 getDemande(date){ ... code ... this.service.getDatas(date).subscribe( res => { ... }, error => { ... }, () => { ... }); ... autre code ... }
Je voudrais appeler cette fonction de la même manière qu'un observable, pour pouvoir gérer le côté asynchrone.

J'ai essayé ça mais ça ne fonctionne pas :

définition :
Code:

1 2 3 4 5 6 7 8 getDemande(date): Observable<any>{ ... code ... this.service.getDatas(date).subscribe( res => { ... }, error => { ... }, () => { ... }); ... autre code ... }
appel :

Code:

this.getDemande(date).subscribe( () => {... traitement lors du retour ...});

ça ne fonctionne pas car dans la définition de la fonction j'ai une erreur sur Observable<any> qui dit "A function whose declared type is neither Void or Any must return a value"

c'est peut être très simple mais je ne suis pas un pro d'angular.
Merci à vous

Code:

1
2
3
4
5
6
7
8
9
10
 
this.getDemande(date).subscribe( (res: any) => { 
    console.log(res);
    ... traitement lors du retour ...
});
...
...
getDemande(date): Observable<any>{
   return this.service.getDatas(date);
}

11/08/2020, 13h26
achem91

Merci pour ton retour, mais l'idée c'était justement de laisser tout le traitement dans la fonction getDemande plutôt que d'avoir à le faire plusieurs fois dans le composant avec l'appel this.getDemande(date).subscribe...

dans ce cas, pas besoin d'un observable, une promesse suffit !

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
getDemande(date) {
   return new Promise((resolve, reject) => {
 
     ... code ...
     this.service.getDatas(date).subscribe(
       (res: any) => {
               console.log(res);
               const data =  ......traitement sur.... res
 
               resolve(data);         // envoi la réponse
       },
       error => { 
          reject(error);
       },
       () => { ... });
 
  });
}

Code:

1
2
3
4
 
this.getDemande(date).then( (res: any) => { 
    console.log(res);
});

11/08/2020, 14h57
achem91

Merci Dukoid, effectivement ça fonctionne comme je le voulais. :bravo: