Wie zu tun Polling mit Angular 2 Observables

Question

Angesichts der folgenden Code, wie kann ich es ändern, um die Get-Anfrage zu "api/foobar" alle 500 Millisekunden wiederholen?

import {Observable} from "RxJS/Rx"; 
import {Injectable} from "@angular/core"; 
import {Http} from "@angular/http"; 

@Injectable() export class ExampleService { 
    constructor(private http: Http) { } 

    getFooBars(onNext: (fooBars: FooBar[]) => void) { 
     this.get("api/foobar") 
      .map(response => <FooBar[]>reponse.json()) 
      .subscribe(onNext, 
        error => 
        console.log("An error occurred when requesting api/foobar.", error)); 
    } 
} 

Answer 1

sicher, Sie haben Import machen importiert {beobachtbare} von 'rxjs/Rx', wenn wir es nicht importieren wir manchmal

nicht gefunden Fehler beobachtbaren erhalten arbeiten plnkr http://plnkr.co/edit/vMvnQW?p=preview

import {Component} from '@angular/core'; 
import {Http} from '@angular/http'; 
import 'rxjs/Rx'; 
import {Observable} from 'rxjs/Rx'; 

@Component({ 
    selector: 'app', 
    template: ` 
     <b>Angular 2 HTTP polling every 5 sec RxJs Observables!</b> 
     <ul> 
     <li *ngFor="let doctor of doctors">{{doctor.name}}</li> 
     </ul> 

     ` 
}) 

export class MyApp { 
    private doctors = []; 

    constructor(http: Http) { 
    Observable.interval(5000) 
    .switchMap(() => http.get('http://jsonplaceholder.typicode.com/users/')).map((data) => data.json()) 
     .subscribe((data) => { 
      this.doctors=data; 
      console.log(data);// see console you get output every 5 sec 
     }); 
    } 
} 

Answer 2

Warum nicht versuchen setInterval()?

setInterval(getFooBars(), 500); 

Answer 3

Versuchen Sie, diese

return Observable.interval(2000) 
     .switchMap(() => this.http.get(url).map(res:Response => res.json())); 

Answer 4

ich empfehle die rx-polling Bibliothek, die abs Trakts viele der Details bietet Mechanismen für Wiederholungen, Back-Off-Strategien und sogar Pause/fortsetzen, wenn Browser-Registerkarte inaktiv wird.