RxJS throwError

創(chuàng)建一個(gè) Observable，不向觀察者發(fā)出任何項(xiàng)目 發(fā)出錯(cuò)誤通知。

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

參量

退貨

Observable<never>：錯(cuò)誤可觀察：僅發(fā)出錯(cuò)誤通知 使用給定的錯(cuò)誤參數(shù)。

描述

只是發(fā)出“錯(cuò)誤”，別無其他。

此靜態(tài)運(yùn)算符可用于創(chuàng)建僅 發(fā)出錯(cuò)誤通知。 它可以用來與其他 可觀測值，例如中的 mergeMap。

例子

發(fā)出數(shù)字7，然后發(fā)出錯(cuò)誤

import { throwError, concat, of } from 'rxjs';


const result = concat(of(7), throwError(new Error('oops!')));
result.subscribe(x => console.log(x), e => console.error(e));


// Logs:
// 7
// Error: oops!

將數(shù)字映射并展平到序列'a'，'b'，'c'，但會拋出錯(cuò)誤2

import { throwError, interval, of } from 'rxjs';
import { mergeMap } from 'rxjs/operators';


interval(1000).pipe(
  mergeMap(x => x === 2
    ? throwError('Twos are bad')
    : of('a', 'b', 'c')
  ),
).subscribe(x => console.log(x), e => console.error(e));


// Logs:
// a
// b
// c
// a
// b
// c
// Twos are bad

也可以看看

• Observable
• empty
• never
• of