As an illustration, let's consider a scenario where I have a timer that emits every 5 seconds and lasts for 10 seconds. By using the scan operator, I can create an observable that includes an array of all the inner observables emitted up until now:
const tick = 5000;
const tock = 1000;
const timers = Observable.interval(tick).scan((acc, next) => {
const timer = Observable.interval(tock).take(10);
return acc.concat([timer]);
}, []);
However, what if I only want to emit an array of "live" timers at any given moment? In other words, I want to exclude those that have already completed.
To better understand this concept, here's a simplified marble diagram:
-A--B-----
\ \
\ \
\ x
x
| | |
[A][A,B] []
My question is whether there exists a standard way or set of operators to achieve this objective in rxjs, or if it is considered unconventional to attempt such a approach.