0 시간에 RxJS Observable 이벤트를 얻는 방법?

Question

나는 data 배열에 관찰 가능한 모든 이벤트를 수집하고 있습니다 :

const obs$ = Rx.Observable 
 
    .interval(500) 
 
    .take(4); 
 

 
let data = []; 
 
const start = performance.now(); 
 

 
obs$.subscribe(
 
    value => { 
 
    data.push({ 
 
     time: performance.now() - start, 
 
     data: value 
 
    }); 
 
    }, 
 
() => {}, 
 
() => { 
 
    console.log(JSON.stringify(data, null, 2)); 
 
    } 
 
);

<script src="https://unpkg.com/rxjs@5.2.0/bundles/Rx.js"></script>

그것은 "미래를 예견"2 초를 기다리지 않고 같은 data 배열 에 접근 가능?

분명히하기 위해 이벤트를 즉시 얻을 수 있도록 주어진 Observable (위 예제의 obs$)을 사용자 지정 타이머/스케줄러로 포장하는 방법을 찾으려고합니다.

Answer 1

VirtualTimeScheduler의 인스턴스를 만들고 interval을 호출하여 지정할 수 있습니다. 당신이 다음에 가입 한 후 스케줄러에 flush를 호출 할 경우

, 이벤트는 즉시 방출됩니다

const scheduler = new Rx.VirtualTimeScheduler(); 
 

 
const obs$ = Rx.Observable 
 
    .interval(500, scheduler) 
 
    .take(4); 
 

 
let data = []; 
 
const start = scheduler.now(); 
 

 
obs$.subscribe(
 
    value => { 
 
    data.push({ 
 
     time: scheduler.now() - start, 
 
     data: value 
 
    }); 
 
    }, 
 
() => {}, 
 
() => { 
 
    console.log(JSON.stringify(data, null, 2)); 
 
    } 
 
); 
 

 
scheduler.flush();

.as-console-wrapper { max-height: 100% !important; top: 0; }

<script src="https://unpkg.com/rxjs@5.2.0/bundles/Rx.js"></script>