如何使用Angular 2 Observable进行轮询

1> Amit kumar..：

---

确保你从'rxjs/Rx'导入导入{Observable}如果我们不导入它我们得到可观察到的错误有时候会发现错误

工作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: `
      Angular 2 HTTP polling every 5 sec RxJs Observables!
      

        
{{doctor.name}}
      

      `
})

export class MyApp {
  private doctors = [];
  pollingData: any;      

  constructor(http: Http) {
   this.pollingData = 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
        });
  }

 ngOnDestroy() {
    this.pollingData.unsubscribe();
}
}

---

这可能很危险 - 如果请求的时间超过5000,则下次运行switchMap时,它将取消之前的请求.因此,如果您的所有请求都花费超过5000,那么每个请求将取消下一个请求,并且您不会进行任何轮询.(5000应该是安全的,但500会太小)

---

如果您不想等待第一个数据5秒钟:`.interval(5000).startWith(0)`

---

如果您担心请求耗时太长,请使用`concatMap`,因为它会跟踪每个请求并按正确的顺序处理它们.