RxJS onErrorResumeNext

當(dāng)任何提供的 Observable 發(fā)出完整或錯(cuò)誤通知時(shí)，它立即訂閱下一個(gè)傳遞的通知。

onErrorResumeNext<T, R>(...sources: any[]): Observable<R>

參量

returns

Observable<R>：一個(gè) Observable，將所有源一個(gè)接一個(gè)地串聯(lián)起來(lái)，而忽略所有錯(cuò)誤，因此任何錯(cuò)誤都會(huì)導(dǎo)致它繼續(xù)移動(dòng)到下一個(gè)源。

描述

不管執(zhí)行什么，都執(zhí)行一系列 Observable，即使這意味著吞咽錯(cuò)誤。

onErrorResumeNext將依次訂購(gòu)它提供的每個(gè)可觀察源。如果其訂閱的源發(fā)出錯(cuò)誤或完成，它將無(wú)誤地移至下一個(gè)源。

如果onErrorResumeNext未提供參數(shù)或單個(gè)空數(shù)組，則它將返回 EMPTY。

onErrorResumeNext基本上是 concat，即使它的一個(gè)來(lái)源發(fā)出錯(cuò)誤，它也只會(huì)繼續(xù)。

請(qǐng)注意，無(wú)法通過(guò)的結(jié)果來(lái)處理源拋出的任何錯(cuò)誤 onErrorResumeNext。如果您要處理任何給定源中引發(fā)的錯(cuò)誤，則可以始終 catchError 在它們上使用運(yùn)算符，然后再將它們傳遞給 onErrorResumeNext。

例

映射失敗后訂閱下一個(gè) Observable

content_copyopen_in_newimport { onErrorResumeNext, of } from 'rxjs';import { map } from 'rxjs/operators'; onErrorResumeNext( of(1, 2, 3, 0).pipe(   map(x => {     if (x === 0) throw Error();     return 10 / x;   }) ), of(1, 2, 3),).subscribe(  val => console.log(val),  err => console.log(err),          // Will never be called.  () => console.log('done'),); // Logs:// 10// 5// 3.3333333333333335// 1// 2// 3// "done"

超載

onErrorResumeNext(v: any): Observable<R>

returnsObservable<R>

onErrorResumeNext(v2: any, v3: any): Observable<R>

returnsObservable<R>

onErrorResumeNext(v2: any, v3: any, v4: any): Observable<R>

returnsObservable<R> onErrorResumeNext(v2: any, v3: any, v4: any, v5: any): Observable<R>

returnsObservable<R> onErrorResumeNext(v2: any, v3: any, v4: any, v5: any, v6: any): Observable<R>

returnsObservable<R> onErrorResumeNext(...observables: any[]): Observable<R>

returnsObservable<R>

onErrorResumeNext(array: any[]): Observable<R>

returnsObservable<R>

也可以看看

• concat
• catchError