Comment lancer une erreur observable manuellement dans angular2?

Je suis en train de travailler sur angular2 application dans laquelle je fais un appel reste via HTTp en tant que ci-dessous:

login(email, password) {
    let headers = new Headers();
    headers.append('Content-Type', 'application/x-www-form-urlencoded');
    let options = new RequestOptions({ headers: headers });
    let body = `identity=${email}&password=${password}`;
    return this.http.post(`${this._configService.getBaseUrl()}/login`, body, options)
    .map((res: any) => {
        let response: any = JSON.parse(res._body);
        if (response.success == 0) {
          Observable.throw(response);  //not working
        } else if (response.success == 1) {
          console.log('success');
          localStorage.setItem('auth_token', 'authenticated');
          this.loggedIn = true;
          return response;
        }
    });
}

fondamentalement, je veux que mon composant pour obtenir de réponse & erreur dans mon abonnez-vous appeler.

c'est à dire

this._authenticateService.login(this.loginObj['identity'],this.loginObj['password']).subscribe(
  (success)=>{      
    this.credentialsError=null;  
    this.loginObj={};  
    this._router.navigate(['dashboard']);    
  },
  (error)=>{
    console.log(error);        
    this.credentialsError=error;     
  }
);

mais mon api renvoie toujours le succès, comme il l'id défini de cette façon.

Donc je veux savoir comment puis-je jeter erreur msg si response.success == 0 , de sorte qu'il sera accessible à l'intérieur de l'erreur argument de mon abonnez-vous de rappel.

source d'informationauteur Bhushan Gadekar

  1. 35
    if (response.success == 0) {
   throw Observable.throw(response);  
 }
  2. 14

    rxjs 6

    import { throwError } from 'rxjs';

if (response.success == 0) {
  return throwError(response);  
}

    rxjs 5

    import { ErrorObservable } from 'rxjs/observable/ErrorObservable';

if (response.success == 0) {
  return new ErrorObservable(response);  
}

    Ce que vous revenir avec ErrorObservable est à vous

  3. 4

    Soit 

    throw response;

    ou

    return Observable.throw(response);  //not working
  4. 0

    Utiliser la capture de l'opérateur

    this.calcSub = this.http.post(this.constants.userUrl + "UpdateCalculation", body, { headers: headers })
   .map((response: Response) => {
      var result = <DataResponseObject>response.json();
         return result;
   })
   .catch(this.handleError)
   .subscribe(
      dro => this.dro = dro,
      () => this.completeAddCalculation()
   );

    Et gérer l'erreur comme ceci:

    private handleError(error: Response) {
    console.error(error); //log to console instead
    return Observable.throw(error.json().error || 'Server Error');
}
  5. 0

    La plupart de mes problèmes étaient liés aux importations, donc voici le code qui a fonctionné pour moi...

    import {_throw} from 'rxjs/observable/throw';
login(email, password) {
...
    return this.http.post(`${this._configService.getBaseUrl()}/login`, body, options)
    .map((res: any) => {
...
        if (response.success == 0) {
           _throw(response);  
        } else if (response.success == 1) {
...
        }
    });
}

    Ce sera la solution si vous êtes confrontés à des erreurs comme...

    ERREUR TypeError:
    WEBPACK_IMPORTED_MODULE_2_rxjs_Observable.Observables.jeter n'est pas une fonction