Rxjs在茉莉花中有效地引发函数错误

Question

我有类似]的效果>

  public save$ = createEffect(() =>
    this.actions$.pipe(
      ofType(saveActions.save),
      map((payload) => payload.info),
      switchMap((info) =>
        of(this.service.save(info)).pipe(
          map(() => 
            saveActions.success({ info });
          ),
          catchError((error) =>
           from([noticiations.error({ message: error.key })]);
          )
        )
      )
    )
  );
service.save执行一些操作，然后返回void，这就是在of中使用switchMap的原因。

此逻辑工作正常。但是现在我正在编写单元测试，

describe((effect) => {
    it('should handle error cases', (done) => {
        const error = { key: 'error' };

        service.save.and.throwError(error);
        actions.next(actions.save({ info }));

        effects.save$.pipe(take(1)).subscribe((resp) => {
            expect(service.save).toHaveBeenCalledTimes(1);
            expect(result).toEqual({
               type: notifications.error.type,
               message: error.key,
            });
        });
    });
});

问题是执行程序永远不会进入effects.save$.pipe(take(2)).subscribe((resp) => {内部>
[当我更改service.save以返回Observable<void>，因此从效果中删除of时，执行工作正常。 

我有一个类似public save $ = createEffect（（）=> this.actions $ .pipe（ofType（saveActions.save），map（（payload）=> payload.info），switchMap（（info）=>的效果）> of（...

Answer 1

我认为您必须将of(this.service.save(info))部分替换为此：

new Observable(s => {
  try {
    this.service.save(info);

    s.next();
  } catch (err) {
    s.error(err);
  }
});