Fre*_*ren 5 rxjs ngrx ngrx-effects angular ngrx-store-4.0
我正在使用@ngrx/store 处理 Angular 防护,以检查状态是否已加载,并且我遇到了一个问题,即canActivate如果我使用过滤器,该方法永远不会返回。
以下是 GetCompanies 操作的示例效果:
return this.companiesService.getCompanies()
.pipe(
map(companies => new companiesActions.GetCompaniesSuccess(companies)),
catchError(error => Observable.of(new companiesActions.GetCompaniesFail(error)))
)
Run Code Online (Sandbox Code Playgroud)
如果出现错误,我将分派 GetCompaniesFail 操作并将用户重定向到/login页面。没关系,有趣的部分是守卫。
@Injectable()
export class CompaniesGuard implements CanActivate {
constructor(
private store: Store<AppState>,
private router: Router
) {}
canActivate(): Observable<boolean> {
return this.checkStore()
.pipe(
switchMap(() => Observable.of(true)),
catchError(() => Observable.of(false))
);
}
checkStore(): Observable<boolean> {
return this.store.select(getCompaniesLoaded)
.pipe(
tap(loaded => {
if (!loaded) {
this.store.dispatch(new companiesActions.GetCompanies());
}
}),
filter(loaded => loaded),
take(1)
);
}
}
Run Code Online (Sandbox Code Playgroud)
如果有错误并且loaded 不是false,则canActivate不会返回任何内容,因为checkStore什么都不做。
如果我改变filter到map它的工作原理,但只需要第一个值,它是false即使数据将被成功加载。
我错过了什么?我如何处理那里的 HTTP 错误?有没有办法等待某个状态或在里面抛出错误checkStore?
预先感谢!
如果你稍微分开一下职责,这似乎更容易处理。
不管怎样,你都应该运行checkStore,而不是直接依赖它的结果。相反,让商店通知您成功或失败并返回该结果。
请注意,ngrx 和 redux 鼓励单向数据流以简化应用程序逻辑。
存储属性getCompaniesLoadedStatus初始化为初始值,并在或内设置为成功或失败。companiesActions.GetCompaniesSuccesscompaniesActions.GetCompaniesFail
重试在服务中处理(更接近提取)。
canActivate(): Observable<boolean> {
this.checkStore();
return this.store.select(getCompaniesLoadedStatus).pipe(
filter(status => status !== 'initial'),
map(status => status === 'success' ? true : false )
);
}
checkStore(): void {
this.store.select(getCompaniesLoadedStatus).pipe(
take(1) // so that unsubscribe is not needed
).subscribe(status =>
if (status === 'initial') {
this.store.dispatch(new companiesActions.GetCompanies());
}
);
}
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
665 次 |
| 最近记录: |