HTTP RxJS i AngularJS - jak mogę to osiągnąć?

Question

Piszę niewielką funkcję użytkową, które owijają wezwanie do angularjs http.get niezbędne nagłówków uwierzytelniania:

get(endpoint: string): Observable { 
    var headers = new Headers(); 
    this._appendAuthentificationHeaders(headers, this.user.credentials); 

    return this.http.get(endpoint, { headers: headers }) 
      .map(res => res.json()); 
} 

Chodzi o to, że jeśli this.user jest null, metoda będzie po prostu wypadek. Więc mam trzy opcje:

1. zwróci null i sprawdzić, czy wartości zwracanej na każde wezwanie ...
2. wyjątek
3. Znajdź sposób, aby również powrócić do zaobserwowania przedmiotu RxJS które będą bezpośrednio wyzwalać obsługa błędów.

Chciałbym wprowadzić trzecią metodę, ponieważ pozwoliłoby to ujednolicić zachowanie tej metody: zawsze zwraca obserwowalne niezależnie od tego, co się stanie.

• Czy masz pomysł, jak to zrobić?
• Czy muszę utworzyć nowy obserwowalny i rodzaj scalenia tych dwóch?
• Co mogę zrobić?

Answer 1

Jeśli user jest null, można po prostu wrócić surowy zaobserwować, że wyzwala błąd:

if (this.user == null) { 
    return Observable.create((observer) => { 
    observer.error('User is null'); 
    }); 
} 

(...) 

lub wykorzystanie operatora throw:

if (this.user == null) { 
    return Observable.throw('User is null'); 
} 

(...) 

ten sposób druga metoda Metoda subscribe zostanie nazwana:

observable.subscribe(
    (data) => { 
    (...) 
    }, 
    (err) => { 
    // Will be called in this case 
    } 
); 

Answer 2

Myślę, że najczystszym sposobem byłoby objęcie całego ciała funkcyjnego obserwowalnym, ponieważ zamieni on dowolny przypadkowy błąd na zauważalny błąd. Coś takiego:

get(endpoint: string): Observable { 
    return Rx.Observable.defer(() => { 
    var headers = new Headers(); 
    this._appendAuthentificationHeaders(headers, this.user.credentials); 
    return Rx.Observable.just(headers); 
    }) 
    .flatMap(headers => this.http.get(endpoint, { headers: headers })) 
    .map(res => res.json()); 
} 

Jednak ja nadal nie zgadzają się z http.get powrocie zauważalny zamiast obietnicy. Ponieważ są to pojedyncze wyceniane obserwable, czynność może być prostą funkcją asynchroniczny (sry, JS zamiast ts):

async get(endpoint) { 
    var headers = new Headers(); 
    this._appendAuthentificationHeaders(headers, this.user.credentials); 
    const res = await this.http.get(endpoint, { headers })).toPromise(); 
    return res.json(); 
}