RxJs: Wie eine Schleife basierend auf dem Status des beobachtbaren?

Ich versuche RxJs, um eine Schleife über einen Beobachtbaren in meinem stream, bis es in einem bestimmten Zustand, dann den stream weiter. Speziell ich die Umwandlung einer synchronen do/while-Schleife RxJs, aber ich nehme an, die gleiche Antwort könnte verwendet werden, für die eine for-oder while-Schleife sowie.

Dachte ich, könnte ich doWhile() für diese, aber es scheint, wie die condition-Funktion nicht haben Zugriff auf das Element in den stream, das scheint die Niederlage der Zweck für mich.

Ich bin mir nicht ganz sicher, was die richtige reaktive Terminologie ist für das, was ich will, aber hier ist ein Beispiel dessen, was ich werde für:

var source = new Rx.Observable.of({val: 0, counter: 3});

source.map(o => {
  o.counter--;
  console.log('Counter: ' + o.counter);

  if (!o.counter) {
    o.val = "YESS!";
  }
  return o;
})
.doWhile(o => { 
  return o.counter > 0; 
})
.subscribe(
    function (x) {
        console.log('Next: ' + x.val);
    },
    function (err) {
        console.log('Error: ' + err);   
    },
    function () {
        console.log('Completed');   
    });

Die erwartete Ausgabe wäre:

Counter: 3
Counter: 2
Counter: 1
Counter: 0
Next: YESS!
Completed

Vorausgesetzt, dies ist ein lösbares problem, ich bin unklar, wie Sie mark das "start" - von wo Sie wollen zurück, wenn Sie die Schleife.

InformationsquelleAutor JBCP | 2015-12-12
  1. 10

    Gibt es die erweitern Betreiber, die Sie schließen, indem Sie rekursiv aufrufen eine Selektor-Funktion. Rückgabe eines leeren beobachtbar wäre dein Durchbruch in diesem Fall. Sehen jsbin:

    var source = Rx.Observable.return({val: 0, counter: 3})
    .expand(value =>  { 
      if(!value.counter) return Rx.Observable.empty();
      value.counter -= 1;
      if(!value.counter) value.val = 'YESS';
      return Rx.Observable.return(value)
    })
    .subscribe(value => console.log(value.counter ? 
                                    'Counter: ' + value.counter : 
                                    'Next: ' + value.val));
    • Hum... interessant, ich könnte in der Lage sein zu machen, dass die Arbeit, ich werde versuchen und post zurück
    • mit dieser, wenn ich es Tat .erweitern Sie().anzeigen() mein downstream-map würde am Ende der Verarbeitung Wert mehrere Male. Ich will den downstream zu verarbeiten nur das Endergebnis. Ich denke, expand().filter().anzeigen() arbeiten könnte.
    • Hm. Der einzige andere Weg, der in den Sinn kommt, so dass zu umgehen, ist die übergabe mehrerer Werte downstream ist ein Thema. Ich würde gerne eine saubere Lösung, die mich :).
    • Ok, ich habe das problem das die Anpassung dieser Lösung ist, dass value.counter ist eine starke Vereinfachung, in Wirklichkeit die exit-Zustand wird bestimmt durch einen anderen asynchronen stream.
    • Ich weiß, es ist eine Menge Arbeit, aber könnte erweitern Sie Ihr Beispiel, um besser zu reflektieren, Ihre situation? Warum kann nicht wieder ein Thema, tun Sie Ihre Arbeit unabhängig von der stream - (du bist also nicht gebunden durch die verfügbaren Beobachtbaren Betreiber) und rufen Sie dann onNext auf das Thema, sobald Sie fertig sind?
    InformationsquelleAutor Niklas Fasching
  2. 5

    Nicht genau, was Sie wollen, aber in der Nähe, mit expand Betreiber, und signalisieren das Ende der Rekursion mit Rx.Observable.empty (http://jsfiddle.net/naaycu71/3/):

    var source = new Rx.Observable.of({val: 0, counter: 3});

source.expand(function(o) {
  console.log('Counter: ' + o.counter);
  o.counter--;

return (o.counter >= 0) ? Rx.Observable.just(o) : Rx.Observable.empty()
})
.subscribe(
    function (x) {
        console.log('Next: ' , x);
    },
    function (err) {
        console.log('Error: ' + err);   
    },
    function () {
        console.log('Completed');   
    });

    Ausgabe :

    Next:  Object {val: 0, counter: 3}
Counter: 3
Next:  Object {val: 0, counter: 2}
Counter: 2
Next:  Object {val: 0, counter: 1}
Counter: 1
Next:  Object {val: 0, counter: 0}
Counter: 0
Completed
    InformationsquelleAutor user3743222
Schreibe einen Kommentar