Marble 用茉莉花大理石测试受试者随时间的行为

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 应用程序的上下文中执行此操作

我的服务，关键部分是我将我的东西定义为吸气剂，让我有机会真正监视，asObservable如果我只是定义things$为属性，那么间谍就不起作用：

@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
      }));
    });
  });