angular - 使用 jasmine-marbles 的 takeUntil-using NGRX 效果测试未按预期完成

Question

给定两个 NGRX 效果（使用 nrwl/nx dataPersistence 表示法），其中第二个通过以下方式绑定到第一个takeUntil：

@Injectable()
export class ModuleEffects {

  @Effect() effectOne$ = this.dataPersistence.fetch(ModuleActionTypes.ActionOne, {
    run: (action: ActionOne, state: ModulePartialState) => {
     return new SomeReturnAction();
    },
  });

  @Effect() effectTwo$ = this.dataPersistence.fetch(ModuleActionTypes.ActionTwo, {
    run: (action: ActionTwo, state: ModulePartialState) => {
      return this.service.apiCall().pipe(
        takeUntil(this.effectOne$),
        map(result => new SomeResultAction(result))
      );
    },
  });

目的是在 effectOne$ 发出后立即因 UI 输入而停止发出 SomeResultAction（效果很好）。

我现在正在尝试使用 jasmine-marbles 库来测试这些效果：

    it('should stop emitting after effectOne$ has emitted', () => {
      const action = new ActionTwo();
      const interruptingAction = new ActionOne();
      const outcome = new SomeResultAction(mockedResult);
      actions = hot('        -a--a-ia|', { a: action, i: interruptingAction });
      const expected = cold('-b--b--b|', { b: outcome });

      expect(effects.effectTwo$).toBeObservable(expected);
    });

即使我希望expectedobservable 在interruptingAction发送后完成，此测试也会成功。