Im folgenden Beispiel istfoo empfängt Daten vonbar ignoriert noch, wennbar wird abgeschlossen.foo ist abgeschlossen, wennbaz wird vervollständigt, was nicht das von mir gewünschte Verhalten ist.

var baz = Rx.Observable.interval( 50 ).take( 10 );

var foo = baz
    .select(function (x) { 
        var bar = Rx.Observable.range(x, 3);
        return bar;
    })
    .switch();

Gibt es eine Variante vonswitch oder eine Technik, die ich verwenden könnte, um das neu erstellte @ zu habfoo beobachtbar haben die gleiche Lebensdauer wiebar? Das heißt, ich möchtefoo ausfüllen, fallsbar wird abgeschlossen.

Lösung

var baz = Rx.Observable.interval( 50 ).take( 10 );

var foo = baz
    .select(function (x) { 
        var bar = Rx.Observable.range(x, 3).materialize()
        return bar;
    })
    .switch()
    .dematerialize();