单元测试期间 Observable.fromPromise 为空

loadAdList$是一个 Observable，它利用了actions$ stream:

loadAdList$: Observable<Action> = this.actions$
    .ofType<adActions.Load>(adActions.LOAD)
    .switchMap((action) => {
      return Observable.fromPromise(store.findAll('ad', action.payload)
        .then((ads) => {
          return new adActions.LoadSuccess(ads);
        })
        .catch((err) => {
          return new adActions.LoadFail(err);
        }));
    });

在浏览器中运行，没有任何问题。但是，我也想对其进行单元测试：

actions$ = hot('-a', { a: loadAction });
const storeResponse = Promise.resolve(mockAds);
const expected$ = cold('-c', { c: loadSuccessAction });

spyOn(store, 'findAll').and.returnValue(storeResponse);

expect(effects.loadAdList$).toBeObservable(expected$);

测试失败并显示以下内容：

Expected 

to deep equal 
    {"frame":10,"notification":{"kind":"N","value":{"payload":"[
    ...

我相信这个问题与store.findAll返回承诺的方法。这是基于以下测试的结果：

.switchMap((action) => {
  // This test will pass
  return Observable.from([new adActions.LoadSuccess(mockAds)]);

  // This test will fail
  return Observable.fromPromise(Promise.resolve(new adActions.LoadSuccess(mockAds)));

});

这有点不幸，但没有很好的方法让 Promise 在 Rx v5 中的 TestScheduler 上下文中同步解析。出于这些原因，如果 Observable 源是从 Promise 开始的，它将无法用于弹珠测试，并且您必须通过订阅以不同的方式创建断言。

Check https://github.com/ReactiveX/rxjs/issues/701 / https://github.com/ReactiveX/rxjs/pull/745如果您想了解失败原因的详细信息。