No exemplo abaixo,foo recebe dados debar ainda ignora quandobar completa.foo é completado quandobaz completa, que não é o comportamento que desejo.

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

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

Existe uma variante deswitch ou uma técnica que eu poderia usar para criar o recém-criadofoo observáveis têm a mesma vida útil quebar? Ou seja, eu gostariafoo para concluir no caso em quebar completa.

Solução:

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();