Как сделать опрос с помощью Angular 2 наблюдаемых

Учитывая следующий код, как его изменить, чтобы запрос на получение "api/foobar" повторялся каждые 500 миллисекунд?

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

Ответ 1

убедитесь, что вы импортировали импорт {Observable} из 'rxjs/Rx', если мы его не импортируем, мы наблюдаем, что иногда не обнаруживаем ошибку

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

Ответ 2

Попробуйте это

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

Ответ 3

Я рекомендую библиотеку rx-polling, которая абстрагирует многие детали, предоставляет механизмы для повторных попыток, стратегии отсрочки и даже паузу /resume, если вкладка браузера становится неактивной.

Ответ 4

Почему бы не попробовать setInterval()?

setInterval(getFooBars(), 500);