Fehlerreaktion Pause valueChanges [Angular2]

Question

Wenn ich subscirbe und für Wertänderungen warten zu bilden, wenn ich brechen resonse Fehler von meinem Service ist ...

Hier Code:

constructor(private fb: FormBuilder, private bankService: BankService) { 
     this.page = 1; 

     this.filter = this.fb.group({ 
      text: ['', []], 
      bankC: ['', []] 
     }); 

     this.filter.valueChanges 
      // wait for a pause in typing of 200ms then emit the last value 
      .debounceTime(200) 
      // only accept values that don't repeat themselves 
      .distinctUntilChanged() 
      // map that to an observable HTTP request, using the TickerLoad 
      // service and switch to that 
      // observable. That means unsubscribing from any previous HTTP request 
      // (cancelling it), and subscribing to the newly returned on here. 
      .switchMap((val: any) => { 
       return bankService.getCountry(val.bankC) 
      }) 
      .subscribe((res) => { 
       console.log(res); 
      }, 
      (err) => { 
       console.log(err); 
      }); 
      // send an empty array to tickers whenever clear emits by 
      // merging in a the stream of clear events mapped to an 
      // empty array. 
    } 

bearbeiten

fand ich, was couse Problem, es innerhalb http intreceptor ist:

intercept(observable: Observable<Response>): Observable<Response> { 
     return observable.catch((err, source) => { 
      if (err.status == 401) { 
       this._router.navigate(['']); 
       return Observable.throw(err); 
       //&& !_.endsWith(err.url, 'api/auth/login') 
      } else { 
       return Observable.throw(err); 
      } 
     }); 

    } 

Es ist dieser Teil: return Observable.throw(err);

Wie kann ich Fehler ohne Bremsabonnement zurückgeben.

Answer 1

Wenn Sie zu der Quelle beobachtbar resubscribe wollen retry() operator vor subscribe():

... 
.switchMap((val: any) => { 
    return bankService.getCountry(val.bankC) 
}) 
.retry(-1) // resubscribe forever 
.subscribe((res) => { 
    console.log(res); 
}, ...