RxJS throwError

2020-10-13 18:52 更新

创建一个 Observable,不向观察者发出任何项目 发出错误通知。

throwError(error: any, scheduler?: SchedulerLike): Observable<never>

参量

错误 要传递给错误通知的特定错误。
调度器 可选的。 默认值为 undefined。  一个 SchedulerLike为计划  错误通知的发出。

退货

Observable<never>:错误可观察:仅发出错误通知 使用给定的错误参数。

描述

只是发出“错误”,别无其他。

扔大理石图

此静态运算符可用于创建仅 发出错误通知。 它可以用来与其他 可观测值,例如中的 mergeMap

例子

发出数字7,然后发出错误

  1. import { throwError, concat, of } from 'rxjs';
  2. const result = concat(of(7), throwError(new Error('oops!')));
  3. result.subscribe(x => console.log(x), e => console.error(e));
  4. // Logs:
  5. // 7
  6. // Error: oops!

将数字映射并展平到序列'a','b','c',但会抛出错误2

  1. import { throwError, interval, of } from 'rxjs';
  2. import { mergeMap } from 'rxjs/operators';
  3. interval(1000).pipe(
  4. mergeMap(x => x === 2
  5. ? throwError('Twos are bad')
  6. : of('a', 'b', 'c')
  7. ),
  8. ).subscribe(x => console.log(x), e => console.error(e));
  9. // Logs:
  10. // a
  11. // b
  12. // c
  13. // a
  14. // b
  15. // c
  16. // Twos are bad

也可以看看

以上内容是否对您有帮助:
在线笔记
App下载
App下载

扫描二维码

下载编程狮App

公众号
微信公众号

编程狮公众号