>我有一个 angualr 7 应用程序,总共 20 个传感器数据。我想每 5 秒使用所选传感器 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);
}
这合适吗?我会根据您的需要更新我的代码,只需在评论部分告诉我。
您可以使用 rxjs forkJoin
它将您所有的可观察量组合成一个发出所有值的可观察量,因此您可以订阅forkJoin发出的可观察量,您可以向其添加管道运算符等
像这样:
let sensors = forkJoin(observable1, observable2)
sensors.subscribe(
sensorData => {
// You receive an object with your observables data
}
)
如果需要获取发出不同值的可变数量的可观察量,则可以通过以下方式使用 BehaviorSubject:
let sensors = new BehaviorSubject<Array<Observables<yourType>>([])
sensors.next([newArrayOfObservables])
sensors.subscribe(
sensors$ => {
sensor$.forEach(sensor => {
sensor.subscribe( // Do your logic)
}
}
)
通过这种方式,您可以添加/删除可观察量,因为 ForkJoin 仅在可观察量完成时发出值,它只发出一次值。
再次记得管理您的退订。