higher-order rxjs observable에서 현재 불완전한 observables를 수집합니다.

Question

예를 들어, 5 초마다 10 초 타이머를내는 observable이 있습니다. 지금까지 방출되는 모든 내부 관찰 가능한 배열 방출이 관측 만들 스캔을 사용할 수 있습니다 (즉, 사람들을 내가 모두의 배열을 방출을 방출 할 경우 타이머 "라이브"무엇

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?

Answer 1

당신은 당신이 원하는 것을 달성하기 위해이 답변에 설명 된 "활성"방법을 사용할 수 있어야합니다 :

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