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?