我正在使用一个IntervalObservable
连续调用我的应用程序的服务器端。我可以订阅和取消订阅 Oberservable,一切正常,但有一个例外:
对服务器的第一次调用会延迟,但我希望它是即时的。该人的行为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);
}
}
那么,如何在第一次调用时立即调用服务器,然后以定义的延迟调用服务器呢?
两件事情,
- 您可以使用工厂方法而不是派生类型,即
Observable.interval(3000)
代替IntervalObservable.create
-
您可以使用timer
使用单个运算符来完成此操作:
return Observable.timer(0, 1000)
.flatMapTo(this.http.get(this.apiURL))
.map(this.extractData)
.catch(this.handleError);
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)