unit-testing - Marble 用 Jasmine 大理石测试受试者随时间的行为

Question

所以我试图测试一个主题的行为，但它不起作用，而且似乎有些事情我没有正确理解。考虑以下测试:

it('marble testing subject test', () => {
    const obs$: Subject<number> = new Subject<number>();

    obs$.next(42);
    obs$.next(24);

    expect(obs$.asObservable()).toBeObservable(hot('xy', { x: 42, y: 24 }));
  });

这失败并显示以下错误消息:

Expected $.length = 0 to equal 2.
Expected $[0] = undefined to equal Object({ frame: 0, notification: Notification({ kind: 'N', value: 42, error: undefined, hasValue: true }) }).
Expected $[1] = undefined to equal Object({ frame: 10, notification: Notification({ kind: 'N', value: 24, error: undefined, hasValue: true }) }).

我想我有点明白为什么: Subject (根据文档)仅在订阅开始后发出值。 toBeObservable()函数(我假设)订阅 Subject所以我的 2 next调用发生在此之前，因此它们不会发出。

所以我的问题是，我将如何测试这样的东西？即随着时间的推移测试来自对象的一系列排放？这可能与大理石测试有关吗？我可以通过将其更改为 ReplaySubject 来使其正常工作。但如果我这样做，大理石图必须是 (xy)而不是 xy .

谢谢。

Answer 1

我在 Angular 应用程序的上下文中进行了这项工作

我的服务，关键部分是我将我的东西定义为 getter，让我有机会实际监视 asObservable如果我刚刚定义了 things$作为属性，则 spy 不起作用:

@Injectable({
  providedIn: 'root'
})
export class ApiService {

  private things = new BehaviorSubject<Array<string>>([]);

  public get things$(): Observable<boolean> {
    return this.things.asObservable().pipe(map((things) => things.length > 0))
  }
}

然后在我的测试中，我想关键部分是我在监视 asObservable things上的方法 BehaviourSubject .像这样:

describe('#things$', () => {

    it('should ', () => {
      const things.   = 'a-b-a';
      const expected =  't-f-t';
      // spy on
      spyOn(service['things'], 'asObservable').and.returnValue(hot(things, {
        a: ['a', 'b'],
        b: []
      }));

      expect(service.things$).toBeObservable(cold(expected, {
        t: true,
        f: false
      }));
    });
  });