rxjs observables ne se termine pas lorsqu'une erreur se produit

Quand je crée une observable à partir de zéro, et ont l'observateur d'erreur, puis les remplir, de la fait partie de l'abonnement n'est jamais invoquée.

var observer = Rx.Observable.create(function(observer){
    observer.onError(new Error('no!'));
    observer.onCompleted();
})

observer.subscribe(
    function(x) { console.log('succeeded with ' + x ) },
    function(x) { console.log('errored with ' + x ) },
    function() { console.log('completed') }
)

La sortie est:

errored with Error: no!

Je m'attends à être:

errored with Error: no!
completed

Si je change le code pour appeler onNext au lieu de onError, observables correctement terminée:

var observer = Rx.Observable.create(function(observer){
    observer.onNext('Hi!');
    observer.onCompleted();
})

observer.subscribe(
    function(x) { console.log('succeeded with ' + x ) },
    function(x) { console.log('errored with ' + x ) },
    function() { console.log('completed') }
)

- Je obtenir le résultat attendu:

succeeded with Hi! 
completed

Pourquoi n'est-il pas terminée quand une erreur s'est produite?

InformationsquelleAutor Oved D | 2015-11-18
  1. 40

    C'est à cause d'une erreur moyen de l'achèvement, de sorte que le rappel associé à onCompleted n'est jamais appelé. Vous pouvez consulter ici Rxjs contrat pour les observables (http://reactivex.io/documentation/contract.html) :

    Observable peut faire zéro ou plus OnNext notifications, chacune représentant une seule émis point, et il peut alors suivre ces émissions de notifications par une OnCompleted ou un OnError de notification, mais pas les deux. Lors de l'attribution d'un OnCompleted ou OnError de notification, il ne peut ensuite émettre des notifications.`

    Pour la gestion d'erreur, vous pouvez jeter un oeil à :
    https://github.com/Reactive-Extensions/RxJS/blob/master/doc/gettingstarted/errors.md

    • Merci! Je vois que cette explication: OnError indique que l'Observable a pris fin avec une condition d'erreur et qu'il sera émettant pas d'autres éléments
    InformationsquelleAutor user3743222
  2. 14

    Alors que j'ai eu la même question, je suis tombé sur ce github problème.

    Apparemment finally méthode de Observable objet doit être utilisé dans ce cas.

    Citant Alexandre-Leotech à partir de ce thread:

    Complète et, enfin, sont des choses totalement différentes. Complète signifie que
    les observables de la vapeur a été terminée avec succès. Parce que vous pouvez avoir
    beaucoup de réussite des appels. Enfin signifie que la vapeur est terminée, soit
    avec succès ou non.

    Il n'est pas évident avec des requêtes HTTP, mais imaginez deux autres
    les scénarios.

    1. Les événements de la souris. Vous recevrez un incessant de la vapeur de succès
      rappels, mais vous ne recevrez jamais de enfin ou complète, parce que
      les événements de l'utilisateur ne sera jamais s'arrêter (sauf si vous déclencher une exception avec
      buggy code, vous obtiendrez une erreur et, finalement).

    2. De travail avec les web sockets. Vous obtiendrez de multiples succès des rappels, mais à un certain point dans le temps votre communication avec les arrêtera et vous obtiendrez à la fois complète et, enfin, sauf si vous avez des erreurs, qui feront appel d'erreur et enfin.

    Donc, vous avez peut-être plusieurs ou pas de succès des appels, zéro ou une erreur d'appel, zéro ou un et zéro ou un, enfin.

    InformationsquelleAutor coni2k