fromPromise 中的 RXJS 抛出错误未命中 'catchError' 管道方法

Question

有人可以解释为什么这个 promise (runQuery) 在“catch”中失败并抛出 ErrorObservable，但没有在“catchError”方法中被捕获，而是进入“map”方法中。
(我尝试了两种 _throw/ErrorObservable 方法，结果相同)

import { _throw } from 'rxjs/observable/throw';
import { ErrorObservable } from 'rxjs/observable/ErrorObservable';

const runQuery = ( Promise that rejects )

const source$ = fromPromise(
  runQuery({ d: 'g' })
    .catch(err => {
      return new ErrorObservable(err);
      //return _throw(err); -- same as above
    })
  )
  .pipe(
    map((response: any) => {
      //ENTERS HERE as response.error     
    }),
    catchError(e => {
      //DOES NOT ENTER
    })
  );

Answer 1

您在 promise 中处理您自己的错误并让它返回一个 ErrorObservable。通过这样做，您使 promise 成功了(尽管有返回值之类的错误)。 fromPromise 会将其转换为发射而不是错误。

删除 fromPromise 中的 catch case，它应该命中 Observable.catchError