Я пытаюсь написать тест для метода компонента, который использует Observable.forkJoin.Я был по всей сети и пробирался сквозь мраморные кроличьи норы, но в конце концов я думаю, что все, что мне действительно нужно, это смоделировать вызов Observable forkJoin и вернуть поддельные данные.Вот мой метод компонента
public loadData(): void {
this.someOtherMethod();
this.someProperty = false;
this.someOtherMethod2();
if (this.isNew) {
this.noData = true;
} else if (this.key) {
Observable.forkJoin([
/*00*/ this.service1$.someCall(this.key),
/*01*/ this.service2$.someCall(this.key),
/*02*/ this.service2$.someCall1(this.key),
/*03*/ this.service2$.someCall2(this.key),
/*04*/ this.service2$.someCall3(this.key),
/*05*/ this.service2$.someCall4(this.key),
/*06*/ this.service2$.someCall5(this.key),
])
.takeWhile(() => this.alive)
.subscribe(
response => {
... // join all the data together
},
// error => this.handleError(error)
);
}
this.changeDetector$.markForCheck();
}
Вот мой тест на данный момент:
it('makes expected calls', async(() => {
const response = [];
const service1Stub: Service1 = fixture.debugElement.injector.get(Service1 );
const service2Stub: Service2 = fixture.debugElement.injector.get(Service2 );
comp.key = key;
spyOn(comp, 'someOtherMethod').and.returnValue(of(response));
spyOn(comp, 'someOtherMethod2').and.returnValue(of(dummyData));
spyOn(service1Stub, 'someCall').and.returnValue(of(dummyData));
spyOn(service2Stub, 'someCall').and.returnValue(of(response));
spyOn(service2Stub, 'someCall1').and.returnValue(of(response));
spyOn(service2Stub, 'someCall2').and.returnValue(of(response));
spyOn(service2Stub, 'someCall3').and.returnValue(of(response));
spyOn(service2Stub, 'someCall4').and.returnValue(of(response));
spyOn(service2Stub, 'someCall5').and.returnValue(of(response));
comp.loadData();
expect(comp.someProperty).toBe(false);
expect(comp.someOtherMethod).toHaveBeenCalled();
expect(comp.someOtherMethod2).toHaveBeenCalled();
expect(service1Stub.someCall).toHaveBeenCalledWith(key);
expect(service2Stub.someCall1).toHaveBeenCalledWith(key);
expect(service2Stub.someCall2).toHaveBeenCalledWith(key);
expect(service1Stub.someCall3).toHaveBeenCalledWith(key);
expect(service1Stub.someCall4).toHaveBeenCalledWith(key);
expect(service1Stub.someCall5).toHaveBeenCalledWith(key);
}));
Я получаю следующую ошибку (после того, как закомментирую описанную выше ошибку):
TypeError: You provided 'undefined' where a stream was expected. You can provide an Observable, Promise, Array, or Iterable.
Мрамор, кажется, заинтересован в проверке наблюдаемого и того, как он реагирует.Я просто хочу увидеть, что звонки совершаются, и провести более глубокое тестирование того, что происходит внутри подписки, где все данные объединяются.
Я знаю, что есть более эффективные способы обработки данных, но для этого требуется капитальный ремонт приложения.Я не могу изменить метод, просто приходится жить так, как сейчас.