angular - 如何终止@ngrx/effects 中的管道操作？

Question

在下面的代码中，我从 Firestore 获取集合的长度。

getUserCartLength(uid:string){
    return this.db.collection('users/'+uid+'/cart').valueChanges()
        .pipe(
            map(docs=>{return docs.length})
        )
}

@ngrx/effects 访问这个方法如下

@Effect()
userExist$ = this.actions$.ofType(UserAuthTypes.YES_USER_EXIST).pipe(
    map((action:YesUserExist)=>action.user),
    switchMap((user)=>{
        return this.userService.getUserCartLength(user.uid)
                .pipe(
                    map(length=>{
                        console.log(length);
                        return new InitializeUserCart(length);
                    })
                )
    }),
)

在组件中，我使用 store 方法在检查用户是否存在后分派(dispatch)操作

ngOnInit() {
  this.logService.isUserExist().subscribe(user=>{
      if(user) this.store.dispatch(new fromUser.YesUserExist(user));
      else this.store.dispatch(new fromUser.NoUser());
  })
}

只要用户登录，一切正常。当用户注销时，它会抛出如下错误

core.js:1673 ERROR Error: Missing or insufficient permissions.

我对这个错误的理解是管道操作仍在尝试访问数据库

有没有办法关闭 ngrx/effects 中的管道操作或任何其他方法请帮助我!

Answer 1

你什么时候做 switchMap 从 stream1 到另一个 stream2 - 仔细检查你真的想听每一个 stream2 除了第一个 Action 。

看来解决方法是在effect中的inner stream中加入first()