I dont get rxjs 6 mit eckiger 6 mit Intervall, switchMap und anzeigen

Ich will update my rxjs code 6 habe ich nicht bekommen.

Ich hatte vor, den unteren, wouth Umfrage für neue Daten alle 5 Sekunden:

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);

Nun...natürlich, es ist gebrochen und die Dokumentation lässt mich nirgendwo zu gehen.

Wie Schreibe ich den obigen entsprechen rxjs 6?

Dank

Es ist gebrochen, wie? Was Sie gearbeitet haben, nur, weil Sie importieren direkt aus rxjs was falsch und importiert alle "Prototyp" - Betreibern, die nicht ist, was Sie wollen, wenn Sie später importieren von import { switchMap, map } from 'rxjs/operators';

InformationsquelleAutor Tampa | 2018-05-06

  1. 33

    Der code sollte etwas wie das folgende. Sie müssen verwenden Sie die pipe Betreiber. 

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

const result = interval(5000).pipe(
switchMap(() => this._authHttp.get(url)),    
map(res => res.results)
)
    Hier ist der Fehler, wenn usijng Ihr Vorschlag: [ts] Eigenschaft 'pipe' existiert nicht auf Typ 'OperatorFunction<{}, {}>'.
    Stellen Sie sicher, fügen Rohr in die Liste importieren: import { Observable -, Intervall -, Rohr -} 'rxjs';
    Ich denke, dieser._authHttp.get(url).Leitung lieber als das._authHttp.get(url) ).Rohr . dies git Beseitigung der Fehler
    Aber jetzt bekomme ich [ts] - Eigenschaft 'json' existiert nicht auf den Typ '{}'. für die res.json()
    Die neue HttpClient gibt nur die Daten, keine Antwort (es sei denn Sie beobachten: 'Antwort' in den Optionen). So können Sie einfach entfernen .json()

    InformationsquelleAutor siva636

  2. 3

    Nach viel Forschung, die ich könnte, kam mit den folgenden aktualisierten Ansatz von RxJs' 6 mit eckiger 6.

    Die such-API aufgerufen wird, nach jedem Intervall von 5 sec und gekündigt, sobald die Zahl > 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();
          }
        });

    API-Anforderung :

       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; 
        })
    );
}

    Vergessen Sie nicht auf Abmelden, um zu vermeiden, Speicherverlust.

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

    }

    InformationsquelleAutor Shahbaaz Khan

Schreibe einen Kommentar