解决这个问题的方法是使用rxjs的take(1)操作符来确保只触发一次查询。下面是一个示例代码:
import { Component, OnInit } from '@angular/core';
import { Observable } from 'rxjs';
import { take } from 'rxjs/operators';
import { MyQuery } from './my-query.service';
@Component({
selector: 'app-my-component',
template: `
{{ data$ | async }}
`,
})
export class MyComponent implements OnInit {
data$: Observable;
constructor(private myQuery: MyQuery) {}
ngOnInit() {
this.data$ = this.myQuery.select().pipe(take(1));
}
refresh() {
this.myQuery.refresh();
}
}
在上面的代码中,我们首先在构造函数中注入了一个名为MyQuery
的查询服务。然后在ngOnInit
方法中,我们使用select()
方法从该查询中获取一个可观察对象,并使用take(1)
操作符确保只触发一次查询。最后,我们将这个可观察对象绑定到模板中的data$
变量上,使用async
管道在模板中订阅和显示数据。
在点击"Refresh"按钮时,我们调用MyQuery
的refresh()
方法来刷新数据。这个方法可能会触发查询,并将更新后的数据保存到存储中。
通过这种方式,我们可以确保只在组件初始化时查询一次数据,而不会在每次变更检测周期中触发查询,从而解决了“Angular 10在从Akita存储查询时未检测到更改”的问题。