Собирание в настоящее время неполных наблюдаемых в наблюдаемых выше наблюдаемых значениях rxjs

Question

Например, у меня есть наблюдаемый, который каждые 10 секунд испускает 10-секундный таймер. Я могу использовать сканирование для создания наблюдаемой, который излучает массив всех внутренних наблюдаемых испускаемых до сих пор:

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

Но что, если я хочу, чтобы излучать испускать массив всех «жить» таймеры (т.е. те, которые еще не звонили complete)?

Вот дерьмовый ASCII мрамор диаграмма того, что я имею в виду:

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

Есть ли способ сделать это с помощью стандартных операторов, или это просто не идиоматическое вещь, чтобы попытаться сделать с rxjs?

Answer 1

Вы должны быть в состоянии использовать «активный» метод, описанный в этом ответе добиться того, что вы хотите:

Rx: a zip-like operator that continues after one of the streams ended?