Как проверить асинхронную функцию, которая использует forkJoin?

Question

[kserg903]

Есть приблизительно такая функция:

public method1(): Observable<any> {
  return forkJoin({
    var1: // some var,
    var2: // some var,
    var3: // some var,
    var4: // some var,
    var5: // some var,
    var6: // some var,
  }).pipe(
    switchMap(data => {
      const res = {
        var1: data.var1,
        var2: data.var2,
        var3: data.var3,
        var4: data.var4,
        var5: data.var5,
        var6: data.var6,
      };
      return of(res);
    }),
  );
}

Она делает 6 асинхронных запросов и объединяет результат в один объект. Я хотел бы написать для неё юнит-тест. Вот моя попытка:

it('should works', fakeAsync(() => {
  component.MyComponent().subscribe(data => {
    expect(data.var1).toEqual(mock1);
    expect(data.var2).toEqual(mock2);
    expect(data.var3).toEqual(mock3);
    expect(data.var4).toEqual(mock4);
    expect(data.var5).toEqual(mock5);
    expect(data.var6).toEqual(mock6);
    tick();
    discardPeriodicTasks();
    component.ngOnDestroy();
  });
}));

Проблема в том, что после запуска тестов консоль выводит следующее сообщение об ошибке:

FAIL: 6 periodic timer(s) still in the queue.

Я понимаю, что 6 запросов асинхронные поэтому оборачиваю тело теста в fakeAsync().

Я понимаю, что тест должен дождаться пока выполнятся все 6 запросов, которые находятся в forkJoin. Поэтому использую tick().

Но всё равно тест не отрабатывает. Помогите пожалуйста исправить его

Comments

[Антон Швец]

Не пробовали вынести сложное объединение в сервис, а в компоненте подписаться как можно проще?
Метод сервиса можно протестить с помощью rxjs-marble, что-то в этом роде.

Чисто по логике даже, это не дело компонента - объединять потоки.

[Demian Smith]

Не совсем понимаю зачем там swtichMap, ведь если его убрать, то результат не изменится.

Попробуйте так:

describe('this test', () => {
  it('looks async but is synchronous', (done) => {
    component.MyComponent().subscribe((data) => {
      expect(data.var1).toEqual(mock1);
      // ...
      done();
    });
  });
});

[kserg903]

Demian Smith, к сожалению done() не решил проблему. Сообщение об ошибке такое:

FAIL: : Timeout - Async callback was not invoked within the 5000ms timeout specified by jest.setTimeout.Timeout - Async callback was not invoked within the 5000ms timeout specified by jest.setTimeout.Error:

А swtichMap мне нужен чтобы объединить все 6 результатов в один объект