RxJS：如何抛出错误然后捕获它？

Question

这与我遇到的错误无关，而是语法问题。

工作流程很简单：

• 发出返回布尔值的 HTTP 请求
• 如果布尔值为真，则继续
• 如果布尔值为假，则记录警告并停止流。

为了管理它，我当前的代码是这样的：

样板文件

private _getBoolean() { return this.http.get(...); }
private _getData() { return this.http.get(...); }

当前代码

public getData() {
  return this._getBoolean().pipe(
    filter(bool => {
      if(!bool) {
        console.warn('Wrong server answer, stream stopped');
        return false;
      }
      return true;
    }),
    switchMap(bool => this._getData())
  );
}

我不知道为什么，但它对我来说并不自然和优化。

我认为会有一些东西可以简化语法，就像这样

public getData() {
  return this._getBoolean().pipe(
    throwError(bool => bool ? new Error('Wrong server answer, stream stopped') : null),
    catchError(err => console.warn(err)),
    switchMap(bool => this._getData())
  );
}

有没有类似的东西，或者我有正确的语法？

Answer 1

我不确定我是否正确地解决了您的问题，但您可以替换

    console.warn('Wrong server answer, stream stopped');
    return false;

有

   Observable.throw('Some error cause')

然后在您的流中用最近的catch 块捕获它，这使您基本上可以更改为： - 如果您重新抛出错误，则停止流 - 如果您返回可观察的输入，请重新启动它 - 返回全新的 observable

public getData() {
  return this._getBoolean().pipe(
    filter(bool => {
      if(!bool) {
        console.warn('Wrong server answer, stream stopped');
        //return false;
        Observable.throw('I got false where I expected true')
      }
      return true;
    }),
    switchMap(bool => this._getData())
  );
}

然后：

getData()
.any()
.operator()
.you()
.wish()
.catch(e => {
  /* Here stream will be terminated on thrown error */
})

Answer 2

考虑下面的 observable，它发出值 1 到 4。假设当值为 3 时抛出错误。该错误可以在 catchError 运算符中捕获，也可以在 subscribe 中捕获。我相信这取决于具体的用例，是让错误一直冒泡到订阅者，还是应该在订阅者上游的某个地方处理。

of(1, 2, 3, 4).pipe(
  // Throw error when value is 3
  tap(value => { if(value === 3) throw new Error('Oops!') }),
  catchError(err => {
    console.log('Catch error in operator', err);

    // You can rethrow the same error or a new error
    // return throwError(err);

    // Or you can handle the error and return a new observable
    return of(3)
  })
).subscribe(
  value => console.log(value),
  // If `catchError` returns a new observable, then the error 
  // function here will not be called
  err => console.log('Catch error within subscribe', err),
  () => console.log('Done!')
)

请注意，在此示例中，即使正在处理错误，observable 也会完成并且永远不会发出值 4。如果您希望在遇到 en 错误时保持 observable 活动，请查看this StackOverflow answer。

Answer 3

代替：

public getData() {
  return this._getBoolean().pipe(
    throwError(bool => bool ? new Error('Wrong server answer, stream stopped') : null),
    catchError(err => console.warn(err)),
    switchMap(bool => this._getData())
  );
}

为什么不这样：

public getData() {
  return this._getBoolean().pipe(
    tap(result => !result && throwError('Wrong server answer, stream stopped')),
    switchMap(bool => this._getData()),
    catchError(err => console.warn(err))
  );
}