Je n'obtiens rxjs 6 angulaire 6 avec intervalle, switchMap, et la carte

Je veux mettre à jour mon rxjs code à 6 got je ne l'obtenez pas.

Avant j'avais le dessous wouth sondage pour les nouvelles données toutes les 5 secondes:

import { Observable, interval } from 'rxjs';
import { switchMap, map } from 'rxjs/operators';

var result = interval(5000).switchMap(() => this._authHttp.get(url)).map(res => res.json().results);

Maintenant...bien sûr, il est cassé et la documentation me laisse aller nulle part.

Comment puis-je écrire ci-dessus pour les rendre conformes à rxjs 6?

Grâce

  • C'est cassé comment? Ce que vous avez travaillé uniquement parce que vous étiez à l'importation directement à partir de rxjs qui est faux et des importations de marchandises "prototype" des opérateurs qui n'est pas ce que vous voulez, si vous importez à partir de import { switchMap, map } from 'rxjs/operators';
InformationsquelleAutor Tampa | 2018-05-06
  1. 34

    Le code doit être quelque chose comme ce qui suit. Vous devez utiliser le pipe de l'opérateur. 

    import { interval } from 'rxjs';
import { switchMap, map } from 'rxjs/operators';

const result = interval(5000).pipe(
switchMap(() => this._authHttp.get(url)),    
map(res => res.results)
)
    • Voici le message d'erreur quand usijng votre suggestion: [ts] Propriété "pipe" n'existe pas sur le type " OperatorFunction<{}, {}>'.
    • Assurez-vous d'ajouter un tuyau dans la liste d'importation: l'importation { Observables, l'intervalle, la pipe } à partir de 'rxjs';
    • Je pense que c'._authHttp.get(url).pipe plutôt que cela._authHttp.get(url) ).la pipe . cette git débarrasser de l'erreur
    • Mais maintenant, je reçois [ts] de la Propriété 'json' n'existe pas sur le type" {}'. pour le res.json()
    • La nouvelle HttpClient retourne uniquement les données, pas de réponse (sauf si vous définissez l'observer: "intervention" dans les options). Ainsi, vous pouvez simplement supprimer .json()
    • probablement vous avez besoin pas de tuyau(res=>res.json().le résultat)

    InformationsquelleAutor siva636
  2. 4

    Après beaucoup de recherche j'ai pu arrivé avec la mise à jour suivant l'approche de RxJs' 6 Angulaire 6.

    L'API de recherche est appelée après chaque intervalle de 5 s et abonné, une fois que le comptage > 5 :

    let inter=interval(5000)

let model : ModelComponent;
model=new ModelComponent();
model.emailAddress="[email protected]";


let count=1;
this.subscriber=inter.pipe(
          startWith(0),
          switchMap(()=>this.asyncService.makeRequest('search',model))
        ).subscribe(response => {
          console.log("polling")
          console.log(response.list)
          count+=1;
          if(count > 5){
            this.subscriber.unsubscribe();
          }
        });

    Demande d'API :

       makeRequest(method, body) : Observable<any> {
    const url = this.baseurl + "/" + method;

    const headers = new Headers();
    this.token="Bearer"+" "+localStorage.getItem('token'); 
    headers.append('Authorization', this.token);
    headers.append('Content-Type','application/json');

    const options = new RequestOptions({headers: headers});
    return this.http.post(url, body, options).pipe(
        map((response : Response) => {
            var json = response.json();                

           return json; 
        })
    );
}

    N'oubliez pas de vous désinscrire pour éviter les fuites de mémoire.

    ngOnDestroy(): void {
if(this.subscriber){
  this.subscriber.unsubscribe();
}

    }

    InformationsquelleAutor Shahbaaz Khan