在 Angular 中使用 Rxjs 进行基本状态管理
Posted
技术标签:
【中文标题】在 Angular 中使用 Rxjs 进行基本状态管理【英文标题】:Basic state management with Rxjs in Angular 【发布时间】:2020-01-26 08:31:13 【问题描述】:我正在尝试在 Angular 中实现基于 Rxjs 的状态管理,但我一直坚持与组件共享状态。
这是我的实现:
private readonly _policies = new BehaviorSubject(<Policy[]>([]));
readonly policies$ = this._policies.asObservable();
get policies(): Policy[]
return this._policies.getValue();
set policies(val: Policy[])
this._policies.next(val);
async fetchAll()
this.policies = await this._policyService.index().toPromise();
async delete(policyId: string): Promise<any>
try
await this._policyService
.destroy(policyId)
.toPromise();
this.policies = this.policies.filter(policy => policy.id !== policyId);
catch (e)
在 shell 组件中,我只是将变量传递给子组件;
<policy-list
[policies]="_policyStoreService.policies$ | async"
(deletePolicyEmitter)="_policyStoreService.delete($event)">
FetchAll 在解析器中被调用;
resolve(route: ActivatedRouteSnapshot): any
return this._leavePolicyStoreService.fetchAll();
我想在我的组件中将 _policyStoreService.policies$
保留为共享的 observable。因此,当我添加/删除/更新策略时,会将更改推送给所有订阅者。在延迟加载模块中也可以使用该服务,并且只有在之前没有加载过的情况下才从 api 获取数据。
问题是我如何将此存储服务用作单例服务。我已经从延迟加载模块的提供程序中删除并将 @Injectable(providedIn: 'root') 插入其元数据。但仍然出现注入错误。
解决方案:我刚刚将 providedIn: 'root' 元数据添加到服务依赖项中。
【问题讨论】:
你为什么不尝试@ngrx?这正是您所需要的。 我之前尝试并使用过 ngRx,但它提供了很多样板代码。我想保持简单。 你只需要用同样多的代码创建一个reducer。而且您不需要做出任何架构决策:) 你有什么问题? “我被卡住了”不足以让我们为您提供帮助。如果您想知道这是否是一个好的模式,答案是肯定的 - 对于简单的应用程序,服务中的Subject
是处理状态的合理方式。 Here 是描述这种模式的文章。如果您在遇到特定问题时需要帮助,我建议您使用StackBlitz 来显示问题。
我已经更新了问题。
【参考方案1】:
您可以在服务中使用简单的 RXJS 主题:
为您服务:
stateChanges: Subject<any> = new Subject<any>();
在您的组件中,您希望向可观察对象发出新事件:
this.yourService.stateChanges.next('Data to emit');
在组件中当你想监听新事件时:
this.yourService.stateChanges.subscribe(data => console.log(data));
** 重要提示:不要忘记取消订阅 observable
【讨论】:
BehaviorSubject
会更好。以上是关于在 Angular 中使用 Rxjs 进行基本状态管理的主要内容,如果未能解决你的问题,请参考以下文章
Angular 7、Ngrx、Rxjs 6 - 访问延迟加载模块之间的状态
在 Angular 10 和 RxJs 中调用了错误的动作类型或错误的减速器