RxJS5 - skipスキップしながら値を保持しますが、スキップしますか？

Question

私はboolが真の間にスキップする必要のあるストリームを持っています。

しかし、そのブール値をfalseに戻すと、スキップしていない最後のストリーム値を適用する必要があります。

Rx.Observable 
.interval(1000) 
.skipWhile(val => true|false)<---when back to false, get last missed value? 
.subscribe(val => console.log(val)); 

Answer 1

マルチキャストを使用して開始値と残りの値を共有します。前と次の値をペアにし、開始と残りを結合するように連結します。

Rx.Observable.interval(500) 
    .multicast(new Rx.Subject(), shared => { 
     let start$ = shared 
        .pairwise() 
        .skipWhile((x)=>x[1]<5) // this is the condition to skip 
        .first()   
        .switchMap(el=>Rx.Observable.concat(Rx.Observable.of(el[0]), 
           Rx.Observable.of(el[1]))); 
     return Rx.Observable.concat(start$, shared); 
}).subscribe(x=>console.log(x));