angular - 开始第一次调用 IntervalObservable 即时

Question

我正在使用 IntervalObservable 连续调用我的应用程序的服务器端。我可以订阅和取消订阅 Oberservable，一切正常，但有一个异常(exception):

对服务器的第一次调用被延迟，但我希望它是即时的。 IntervalObservable 的行为原则上是正确的，但不符合我的要求。

@Injectable()
export class LoggerService {
  constructor(private http: Http) { }
  private apiURL = 'assets/file.json'; 

  getList() {
       return IntervalObservable.create(1000).flatMap(() 
       => this.http.get(this.apiURL))
      .map(this.extractData)
      .catch(this.handleError);
  }
  private extractData(res: Response) {
    var fooot = new Foo();
    fooot.fillFromJSON(JSON.stringify(res.json()));
    return fooot;
  }

  private handleError(error: any) {
    let errMsg = (error.message) ? error.message :
      error.status ? `${error.status} - ${error.statusText}` : 'Server error';
    console.error(errMsg);
    return IntervalObservable.throw(errMsg);
  }
}

那么我怎样才能在第一次调用时立即调用服务器，然后在定义的延迟后调用服务器呢？

Answer 1

两件事，

1. 您可以使用工厂方法而不是派生类型，即 Observable.interval(3000) 而不是 IntervalObservable.create

2. 您可以使用 timer 来代替单个运算符:

   return Observable.timer(0, 1000)
     .flatMapTo(this.http.get(this.apiURL))
     .map(this.extractData)
     .catch(this.handleError);