如何在takeWhile条件下的效果中发出错误？

Question

我有一个效果，如果同一个用户没有被点击，就会做一些事情，以避免不必要的请求，正确吗？

这段代码是可行的，但是当它落入已经被点击的同一个用户，再次被点击的条件时，它不会向Store发出任何错误，从而不会产生任何下一个效果。

在我的逻辑中，如果我的takeWhile不满足，如何返回一个错误？

updatePartial$: Observable<Action> = createEffect(() =>
    this.action$.pipe(
        ofType(fromPeopleActions.UPDATE_MANY_PARTIAL),
        withLatestFrom(this.selectorsService.userFriendClicked),
        takeWhile(([action, userFriendClicked]) => action.updates.id !== userFriendClicked.id),
        switchMap(([action, userFriendClicked]) => {
            console.log('oi');
            const peoples: Update<IPeople>[] = [];
            const https: Observable<Update<IPeople>>[] = [];

            peoples.push(action.updates);
            peoples.push({
                ...userFriendClicked,
                changes: {
                    isClicked: false,
                },
            });

            peoples.forEach((people) => https.push(this.backendService.updatePartial(people)));

            return forkJoin(https).pipe(
                map(() => fromPeopleActions.UPDATE_MANY_PARTIAL_SUCCESS({ updates: peoples })),
                catchError((error) => of(fromPeopleActions.UPDATE_MANY_PARTIAL_FAIL({ error: this.requestHandlerService.getError(error) })))
            );
        })
    )
);

Answer 1

由于RxJS 6.4.0。takeWhile 取一个可选参数 inclusive 会发出第一个没有通过谓词的项目。

然而在你的例子中，你需要抛出一个错误而不是最后一个失败的项目，这样它就会由 catchError 操作员。一个变通的方法是使用 concatMap 之前 takeWhile 并在失败时抛出一个错误。试试下面的方法

updatePartial$: Observable<Action> = createEffect(() =>
  this.action$.pipe(
    ofType(fromPeopleActions.UPDATE_MANY_PARTIAL),
    withLatestFrom(this.selectorsService.userFriendClicked),
    concatMap(([action, userFriendClicked]) => {
      if (action.updates.id !== userFriendClicked.id) {
        return of([action, userFriendClicked]);
      }
      return throwError('Same user clicked');
    }),
    takeWhile(([action, userFriendClicked]) => action.updates.id !== userFriendClicked.id),
    .
    .