RxJs - 有损 zip 弹珠测试答案

【问题标题】：RxJs - lossy zip marble testingRxJs - 有损 zip 弹珠测试
【发布时间】：2022-04-25 20:39:25
【问题描述】：

在this 发布之后，我决定为这个运算符写一个marble test。

这是一个基本测试：

  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()
);

我希望得到的 observable 看起来像这样：

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

或者至少是这样的：

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

但是他们都失败了。

这是jasmine-marbles 中的错误还是我的预期有误？

【问题讨论】：

问题在于您对大理石语法的理解。同步组（例如(12)）的发射发生在第一帧（带有( 字符的帧），但语法实际上跨越了多个帧。相关：stackoverflow.com/q/46839094/6680611
哦，我明白了...我想我应该更彻底地阅读文档。所以TestScheduler 的行为不仅是组的内部占用了适当数量的帧，而且还占用了括号。在这种情况下，我的测试弹珠应该类似于：hot('a------a---------a---') 和 hot('--b-------b----b-----')，输出将是 cold('--(12)----(12)---(12)')。如果你不介意用这个例子回答这个问题，我会接受你的回答。感谢您的帮助！
不用担心。我也没有仔细阅读文档，我记录了我的经历here。
关于回答，我很懒。你呢self-answer it？那么我所要做的就是点赞。

标签： javascript jasmine rxjs rxjs5 jasmine-marbles

【解决方案1】：

显然，根据官方documentation（我没有仔细阅读）括号以及该组的内容占用了相关的帧数：

'--(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);
  });

【讨论】：