Jak zgłosić błąd z operatora mapy RxJS (kątowy)

Chcę zgłosić błąd z operatora mapy mojego obserwowalnego na podstawie warunku. Na przykład, jeśli nie otrzymano poprawnych danych API. Zobacz poniższy kod:

private userAuthenticate( email: string, password: string ) {
    return this.httpPost(`${this.baseApiUrl}/auth?format=json&provider=login`, {userName: email, password: password})
        .map( res => { 
            if ( res.bearerToken ) {
                return this.saveJwt(res.bearerToken); 
            } else {
                // THIS DOESN'T THROW ERROR --------------------
                return Observable.throw('Valid token not returned');
            }
        })
        .catch( err => Observable.throw(this.logError(err) )
        .finally( () => console.log("Authentication done.") );
}

Zasadniczo, jak widać w kodzie, jeśli odpowiedź (obiekt res) nie ma „bearerToken”, chcę wyrzucić błąd. Więc w mojej subskrypcji trafia do drugiego parametru (handleError) wspomnianego poniżej.

.subscribe(success, handleError)

Jakieś sugestie?

Po prostu wrzuć błąd do wnętrza map()operatora. Wszystkie wywołania zwrotne w RxJS są opakowane blokami try-catch, więc zostaną przechwycone, a następnie wysłane jako errorpowiadomienie.

Oznacza to, że nic nie zwracasz i po prostu wyrzucasz błąd:

map(res => { 
  if (res.bearerToken) {
    return this.saveJwt(res.bearerToken); 
  } else {
    throw new Error('Valid token not returned');
  }
})

throwError()(Dawniej Observable.throw()w RxJS 5) jest zauważalny, które po prostu wysyła errorpowiadomienie, ale map()nie obchodzi mnie to, czego wracać. Nawet jeśli zwrócisz z map()niego Observable , zostanie przekazane jako nextpowiadomienie.

Ostatnia rzecz, prawdopodobnie nie musisz jej używać .catchError()(poprzednio catch()w RxJS 5). Jeśli potrzebujesz wykonać jakieś efekty uboczne, gdy wystąpi błąd, lepiej użyć na przykład tap(null, err => console.log(err))(dawniej do()w RxJS 5).

Sty 2019: Zaktualizowano dla RxJS 6

Jeśli throw new Error()wydaje ci się, że wydaje się nieobserwowalne - tak jak możesz użyć throwError(...)z switchMapzamiast map(różnica polega na tym, że switchMapzwraca nową obserwowalną):

// this is the import needed for throwError()
import { throwError } from 'rxjs';


// RxJS 6+ syntax
this.httpPost.pipe(switchMap(res => { 
   if (res.bearerToken) {
      return of(this.saveJwt(res.bearerToken)); 
   } 
   else {
      return throwError('Valid token not returned');  // this is 
   }
});

lub bardziej zwięźle:

this.httpPost.pipe(switchMap(res => (res.bearerToken) ? 
                                    of(this.saveJwt(res.bearerToken)) : 
                                    throwError('Valid token not returned')
));

Zachowanie będzie takie samo, to po prostu inna składnia.

Dosłownie mówisz „przełącz” z http obserwowalnego w potoku na inną obserwowalną, która jest albo po prostu „zawijaniem” wartości wyjściowej, albo nowym obserwowalnym „błędem”.

Nie zapomnij wstawić of, bo otrzymasz mylące komunikaty o błędach.

Piękno „switchMap” polega również na tym, że jeśli chcesz, możesz zwrócić cały nowy „łańcuch” poleceń - bez względu na to, z jaką logiką trzeba się uporać saveJwt.

Chociaż na to pytanie już udzielono odpowiedzi, chciałbym podzielić się moim podejściem (chociaż różni się ono tylko nieznacznie od powyższego).

Zdecydowałbym, co jest zwracane niezależnie od mapowania i na odwrót. Nie jestem pewien, który operator jest najlepszy do tego, więc użyję tap.

this.httpPost.pipe(
  tap(res => { 
    if (!res.bearerToken) {
      throw new Error('Valid token not returned');
    }
  }),
  map(res => this.saveJwt(res.bearerToken)),
);