單元測試Observable.interval

Question

我有一個函數可以查詢api，直到返回所需的結果或者達到超時時間。

// sample poll, filter and timeout 
    pollStatus =(): Observable<string> => { 
      return Observable.interval(1000) 
       .mergeMap(() => this.getStatus(); // this makes a http call to a status api 
       .map((response) => response.json()) 
       .filter((responseData) => responseData.status !== 'PENDING') 
       .take(1) 
       .map((response) => response.status) 
       .catch((error) => Observable.throw({message: 'FAILED'})) 
       .timeout(5000); 
      }; 

在我的測試我想執行的pollStatus（）函數，並確保的getStatus（）函數被調用的時間等正確的號碼，但我不能活動得到它調用它一次。測試Observable.interval的最佳方式是什麼，以及如何強制發生新的時間間隔？

Answer 1

要測試Rx代碼，您需要通過VirtualTimeScheduler，這樣您才能在測試中提前計算時間。您可以使用compat的包@kwonoj/rxjs-testscheduler-compat所以你可以寫在RxJs5測試，你會在RxJs4已經寫了他們：

import { TestScheduler, next, complete } from '@kwonoj/rxjs-testscheduler-compat'; 

const scheduler = new TestScheduler(); 
const results = scheduler.startScheduler(
() => pollStatus(scheduler), 
    { created: 100, subscribed: 200, unsubscribed: 4000 } 
); 

您需要調度傳遞到基於時間的運營商，使他們將安排他們的工作不在默認的調度，但您提供的一個：

pollStatus = (scheduler?:Rx.Scheduler): Observable<string> => { 
    return Observable.interval(1000, scheduler) 
    .mergeMap(() => this.getStatus(); // this makes a http call to a status api 
    .map((response) => response.json()) 
    .filter((responseData) => responseData.status !== 'PENDING') 
    .take(1) 
    .map((response) => response.status) 
    .catch((error) => Observable.throw({message: 'FAILED'})) 
    .timeout(5000, scheduler); 
}; 

然後，您可以觀察到你的代碼在虛擬時間運行在您的測試，然後你就可以開始爲this.getStatus()創建嘲笑有它慢則5000毫秒所以你的timeout()命中等