Publier la dernière valeur d'une observable

J'ai un chaud observables (un sujet, dans ce cas):

var subject = new Rx.Subject();

Je veux créer un autre observable que chaque fois qu'un nouvel abonnement est effectué immédiatement les feux de la dernière valeur qui a été produit.

Donc en pseudo code:

var myObservableWithLastValue = subject.publishLast();

subject.onNext(3);

myObservableWithLastValue.subscribe(function(x){
    console.log(x); //should write 3
});

myObservableWithLastValue.subscribe(function(x){
    console.log(x); //should write 3, too
});

subject.onNext(4);

myObservableWithLastValue.subscribe(function(x){
    console.log(x); //should write 4
});

C'est à peu près ce que je veux et il semble fonctionner. Cependant, je suppose qu'il doit être intégré dans le mécanisme pour obtenir le même

Rx.Observable.prototype.keepLatest = function () {
    var latestValue;

    var disposable = this.subscribe(function (value) {
        latestValue = value;
    });

    return Rx.Observable.create(function (observer) {
        observer.onNext(latestValue);
        return disposable.dispose;
    });
};
InformationsquelleAutor Christoph | 2012-03-16
  1. 18

    RxJs a maintenant la ReplaySubject. L'initialiser avec 1 tampon et que vous avez la BehaviorSubject.

    JS:

    //as an example, use buffer size of 2
var subject = new Rx.ReplaySubject(2 /* buffer size */);

subject.onNext('a');
subject.onNext('b');
subject.onNext('c');

subject.subscribe(function (x) { document.write('x1:' + x + '<br>'); });

subject.onNext('d');

subject.subscribe(function (x) { document.write('x2:' + x + '<br>'); });

    HTML:

    <script src='https://rawgit.com/Reactive-Extensions/RxJS/v.2.5.3/dist/rx.all.js'></script>

    • Pouvez-vous me dire quelle est la principale différence entre votre code et l'original? Je crains que je suis absent quelque chose. En outre, il définit la taille de la mémoire tampon de 2 si les 2 dernières valeurs sont relus à chaque fois.
    • Aucun. Je viens de faire l'exemple interactif et complet. La taille de la mémoire tampon est utilisée pour démontrer la différence de l'utilisation de BehaviorSubject dans le @Asti réponse. C'est la raison je n'ai pas de créer une nouvelle asnwer, mais seulement contribué à la vôtre.
    • Ok. Je vois votre point de vue. L'amélioration d'un peu plus de montrer les résultats de recherche dans la fenêtre au lieu de la console 🙂
    • Vous ne devriez vraiment pas être à l'aide de document.write à cette fin. console.log permet d'inspecter et d'interagir avec la sortie. C'est une opinion basée sur la suggestion, cependant.
    • Avec la console.journal vous ne pouvez pas voir quoi que ce soit dans la fenêtre des résultats. Avez-vous une meilleure suggestion? console.le journal est ok, mais pas trop interactif
    • C'est à dessein que vous ne pouvez pas voir quoi que ce soit dans la fenêtre du navigateur... parce que vous pouvez tout voir dans votre fenêtre de Console (outils de dev).

    InformationsquelleAutor allprog
  2. 6

    BehaviorSubject:

    Initialise une nouvelle instance de la Rx.BehaviorSubject classe qui crée un objet qui cache son dernier valeur et commence avec la valeur spécifiée.

    JS:

    var subject = new Rx.BehaviorSubject('a' /* initial value */);

subject.subscribe(function (x) {
    console.log('x1:' + x);
});

subject.onNext('d');

//Will produce the last value.

subject.subscribe(function (x) {
    console.log('x2:' + x);
});

    HTML:

    <script src='https://rawgit.com/Reactive-Extensions/RxJS/v.2.5.3/dist/rx.all.js'></script>

    • Ok, mais n'est-il pas construit dans de l'opérateur qui prend un flux existant et s'applique l'esquisse du comportement?
    • Avez-vous essayé de troquer votre sujet quelconque pour un BehaviorSubject?
    • Je ne suis pas le traitement de sujets directement. C'était juste pour illustrer le comportement de mieux. Je veux un opérateur qui s'applique sur tout chaud courant infini.
    • Les sujets en oeuvre à la fois IObserver<T>, et IObservable<T>. Vous devriez être en mesure d'obtenir le comportement sujet à s'abonner à votre IObservable, puis à son tour de s'Abonner à la BehaviorSubject
    InformationsquelleAutor Asti
  3. 0

    J'ai utilisé .cache(1) sur une chaude Observable. Semble donner le comportement que vous avez demandé (mais je suis un novice).

    observables que chaque fois qu'un nouvel abonnement est effectué immédiatement les feux de la dernière valeur qui a été produit.

    • Pour info, ma compréhension est que cache a été supprimé à partir de la prochaine version.
    InformationsquelleAutor verylongword