jeter de l'erreur à l'intérieur rxjs Observables

Je suis en train de jeter une erreur à l'intérieur d'un rxjs Observables

 new Observable(subscriber => {
   Observable.throw("error1");
   return Observable.throw("error2");
 })
 .subscribe(
   () => {},
   err => console.error(err)
 );

erreur 1 n'est pas pris.

error2 donne une erreur de compilation:

Argument of type '(this: Observable<{}>, subscriber: Subscriber<{}>) => ErrorObservable<string>' is not assignable to parameter of type '(this: Observable<{}>, subscriber: Subscriber<{}>) => TeardownLogic'. Type 'ErrorObservable<string>' is not assignable to type 'TeardownLogic'

quelle est la bonne façon de jeter une erreur à l'intérieur d'une observable?

essayez de lancer une erreur comme Observable.throw(new Error("error1")).
ne fonctionne pas. Il n'est pas pris par le subscribe()

OriginalL'auteur phzonta | 2017-02-15

  1. 3

    Lors de l'utilisation de new Observable() ou Observable.create() vous pouvez le pousser à l'erreur directement à l'abonné (observateur):

    Observable.create(subscriber => {
   subscriber.error(new Error("error1"));
 })
 .subscribe(
   () => {},
   err => console.log(err.message)
 );

    La fonction anonyme transmise à new Observable() peut éventuellement retourner un de désabonnement de rappel. C'est pourquoi il vous donne le message d'erreur parce que vous êtes de retour d'une Observable.

    À l'aide de Observable.throw("error1") n'est habituellement pas nécessaire. C'est juste une Observable qui émet seulement une erreur et rien de plus. Vous pouvez l'utiliser par exemple comme le suivant:

    Observable.create(subscriber => {
    subscriber.next('whatever');
  })
  .merge(Observable.throw(new Error("error2")))
  .subscribe(
    () => {},
    err => console.log(err.message)
  );

    Voir la démo en live: https://jsbin.com/fivudu/edit?js console

    ainsi sont jetées les erreurs à l'intérieur d'un producteur throw new Error() sont pratiquement ignorées et non déclarés?

    OriginalL'auteur martin

  2. 1

    Avec une observable que vous avez créé vous-même, vous avez accès à la observer.error() méthode.

    const obs = Observable.create(observer => {

  //Emit a value.
  observer.next("hello");

  //Throw an error.
  observer.error("my error");

});

    Remarque: si vous utilisez RxJS 4, vous devrez utiliser onNext() et onError() à la place.

    OriginalL'auteur AngularChef