Я пытаюсь написать модульный тест для наблюдаемой функции rxjs, похожей на эту
return Rxjs.waitForObservables(networkRequests).do(
() => {
//some logic called
}
Наблюдаемая функция выглядит так
static waitForObservables(observables: Array<Observable<any>>): Observable<any> {
// forkJoin returns an observable that emits one time, once all observables complete
return observables.length > 0 ? Observable.forkJoin(observables) : Observable.of(null);
}
После внедрения всехзависимости, слежка за
spyOn(Rxjs, 'waitForObservables').and.callThrough();
Проверка функции, вызываемой так:
expect(Rxjs.waitForObservables).toHaveBeenCalled();
Я пытаюсь проверить код внутри блока rxjs.