2016-08-12 5 views
0

例えば、私は10秒タイマーを5秒ごとに発行するobservableを持っています。私は、これまでに放出されるすべての内部観測の配列を発すること、観察を作成するためにスキャンを使用することができます高次rxjs observableで現在不完全なobservablesを収集する

tick = 5000 
tock = 1000 
timers = Observable.interval(tick).scan((acc, next) => { 
    let timer = Observable.interval(tock).take(10); 
    return acc.concat([timer]); 
}, []); 

しかし、私はそれらのすべての「ライブ」タイマー(すなわちの配列を放出するためにそれを放出する場合completeはまだ呼び出されていない)ここで

は、私はと思っていの安っぽいアスキー大理石の図です:標準の演算子を使ってこれを行う方法はあり

-A--B----- 
    \ \ 
    \ \ 
    \ x 
    x 
| | | 
[A][A,B] [] 

、またはを実行しようとするには、このだけでは慣用のものですrxjs?

答えて