RxJs -有损拉链大理石测试

Question

在这文章之后，我决定为这个操作符编写一个大理石试验。

下面是一个基本的测试：

  it('Test lossy zip', () => {

    const a = hot('a---a--------a-');
    const b = hot('--b----b---b---');

    const observable = zip(
      a.pipe(take(1)),
      b.pipe(take(1))
    ).pipe(
      mergeMapTo(from(['1'])),
      repeat()
    );
    const expected = cold('--1----1-----1-');
    expect(observable).toBeObservable(expected);
  });

此测试如预期的那样通过。然而，当我决定排放两种排放物，像这样，它就失败了：

const a = hot('a---a--------a-');
const b = hot('--b----b---b---');

const observable = zip(
  a.pipe(take(1)),
  b.pipe(take(1))
).pipe(
  mergeMapTo(from(['1', '2'])), //Here, emitting two items instead of one
  repeat()
);

我希望由此可以观察到的结果如下所示：

const expected = cold('--(12)----(12)-----(12)-');

或者至少像这样：

const expected = cold('--12---12----12-');

然而，两者都失败了。

它是jasmine-marbles中的一个bug，还是我的期望是错的？

Answer 1

显然，根据官方的文档 (我还没有仔细阅读)，括号和组的内容占据了相关帧的数量：

'--(abc)-|'：在帧20上，发出a、b和c，然后在帧80 complete上发出

这意味着对群体排放的有效测试将如下所示：

  it('Should emit a grouped value', () => {

    const a = hot('a------a---------a---');
    const b = hot('--b-------b----b-----');

    const observable = zip(
      a.pipe(take(1)),
      b.pipe(take(1))
    ).pipe(
      mergeMapTo(from(['1', '2'])),
      repeat()
    );

    const expected = cold('--(12)----(12)---(12)');
    expect(observable).toBeObservable(expected);
  });