RxJs : 미리 정의 된 시간에 이벤트를 방출하는 방법은 무엇입니까?

Question

특정 시간에 발생하도록 미리 정의 된 이벤트가 있습니다. 그리고이 같은 타이머를 가지고 : (실제로는 완전히 괜찮 더 같은 101200302401500을 ... 비록)

const timer = Rx.Observable.interval(100).timeInterval() 
    .map(x => x.interval) 
    .scan((ms, total) => total + ms, 0) 

타이머는 100200300400500에 가까운 무언가를 방출 나는 또한 내가하고 싶은 몇 가지 물건을 가지고 특정 시간에. 결과 스트림이 한 번 당 값을 방출하는 것을

const stuff = Rx.Observable.from([1000, 2000, 2250, 3000, 5000]); 

내가 원하는 것은 그런 방법으로 "재료"와 "타이머"를 결합하는 것입니다 : 예를 들어, 나는 다음과 같은 시간에 물건을하고 싶은 말을하자 그 시간에 "stuff"에 정의 된 시간 (또는 약간 나중에). 이 경우 t = 1000 ms, 2000 ms, 2250 ms, 3000 ms 및 5000 ms가됩니다. 참고 : 2250 사람은 간격 크기로 인해 2300 년경에 방출해야합니다. 괜찮아. 그들은 일찍 또는 한 번 이상 올 수 없습니다.

나는 하나의 해결책이 있지만 그다지 좋지 않습니다. 매 단계마다 (이 경우 100 밀리 초마다) "stuff"를 다시 시작하고 1을 취합니다. 이벤트가 "stuff"에서 방출되면 사라질 것입니다. 그 값들은 없습니다. 실제 응용 프로그램에서

는 ... 물건과 stuff2 어쩌면 stuff3있을 것입니다 (하지만 난 뭔가! 그들을 호출) 사전에

감사합니다! 나는 그것이 분명했기를 바란다.

Answer 1

내가 제대로 계신 이해했다면,이 간단한 돌출부와 달성해야한다 : 두 번째를 들어 https://jsbin.com/negiyizibu/edit?html,js,console,output

편집

: 여기

const times$ = stuff.flatMap(x => Rx.Observable.timer(x)); 

는 작업 예제입니다 요구 사항을 다음과 같이 시도하십시오.

const times$ = Rx.Observable 
       .from([{"val":"jeff", "t": 1000}, {"val":"fred", "t": 2500}]) 
       .flatMap(x => Rx.Observable.timer(x.t).map(y => x.val)); 

https://jsbin.com/cegijudoci/edit?js,console,output