我有一个 angualr 7 应用程序,总共有 20 个传感器数据。我想每 5 秒使用 observable 为选定的传感器 ID 接收一次数据。例如;
var sensorId = ""; // dynamically selected from the web UI
var sensorData$ = interval(5000).pipe()
sensorData$.subscribe() // etc..
我将选择多个传感器,并开始使用间隔订阅获取数据。我怎样才能保留这些观察值?我该如何管理它?
此外,我可以随时添加任何传感器。
最佳答案
我建议使用 Subject 和 mergeMap。
至于解释,您将有 1 个主题,当用户从 UI 中选择一个时,您将在其中发出新的 sensorId。然后您需要订阅那个确切的主题,并且在 mergeMap 的帮助下,您将在订阅方法中拥有所有传感器值。
让我们看一下演示代码:
private sensorIdSubject = new Subject();
ngOnInit() {
this.sensorIdSubject.pipe(
mergeMap(sensorId =>
interval(5000).pipe(switchMap(() => this.getSensorData(sensorId)))
).subscribe(sensorData => {
// Every 5 second, each of the sensorIds that have been selected in UI will
// get sensor data and emit new value here in subscribe, because all of them
// have been merged.
})
}
public chooseSensor(sensorId) {
this.sensorIdSubject.next(sensorId);
}
这个合适吗?我会根据您的需要更新我的代码,请在评论部分告诉我。
关于javascript - 如何在 Angular 7 中管理多个可观察对象,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57073941/