rxjs бросает ошибку после того, как HTTP-запрос возвращает определенное значение

Question

Я написал запись Observable, которая запрашивает URL-адрес, который завершается после возвращения определенного значения.

private checkPairingStatus(paringModel: any): Observable<ResponseObject> { 
    let data = { id: 1234 }; 
    return Observable 
     .interval(2000) 
     .switchMap(() => this.get<ResponseObject>('http://api/getstatus', data)) 
     .first(r => r.Status === 'success') // once our pairing is active we emit that 
     .timeout(90000, Observable.throw(new Error('Timeout ocurred'))); 
     // todo: find a way to abort the interval once the PairingStatus hits the 'canceled' status. 
} 

Это работает довольно хорошо, но я изо всех сил о том, как бросить исключение только мой respone, например, попадает в следующий статус «r.Status ===" отмененный».

Спасибо за любой намек на это!

С уважением Lukas

Answer 1

Вы можете просто использовать do() и бросить Error с любым условием вам нужно:

return Observable 
    .interval(200) 
    .do(val => { 
     if (val == 5) { 
      throw new Error('everything is broken'); 
     } 
    }) 
    .subscribe(
     val => console.log(val), 
     err => console.log('Error:', err.message) 
    ); 

Печатается утешать:

0 
1 
2 
3 
4 
Error: everything is broken 

В вашем случае» Я хочу проверить состояние, такое как r.Status === 'canceled' или что угодно.