在我的组件 html 中,我使用 asyncPipe 来订阅此 http 服务。该服务将 json 响应对象映射到类实例数组。这一切都很好,但我希望 http 服务每隔几秒轮询一次。我已经尝试了很多东西(比如间隔),但目前 RXJS 似乎有点雷区。有人使用 Angular 6 实现过这种事情吗?
fetch(command, params?) {
return this.http.post(`http://localhost:4000/${command}`, params)
.pipe(
map((data: Data) => {
const statuses: Status[] = [];
for (const statusKey of Object.keys(data.statuses)) {
const newStatus = new Status(
// do some object translation...
);
statuses.push(newStatus);
}
return statuses;
})
)
.pipe(
catchError(EpisodeApiService.handleError)
);
}
这应该像下面这样简单:
pollInterval = 5000;
const httpObservable = interval(pollInterval).pipe(
switchMap(x => fetch(command, params?) )
);
The pollInterval
可以根据要求进行更改。interval
and switchMap
应按如下方式导入:
import { interval } from 'rxjs';
import { switchMap } from 'rxjs/operators';
Using switchMap
这里有助于取消任何延迟的待处理 http 请求,这对性能有好处,特别是在间歇性 Internet 连接期间。这就是为什么 RxJS 响应式方法比传统方法(例如setInterval()
.
最后还应该进行订阅,否则什么也不会发生:
httpObservable.subscribe(x => {});
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)