Как проверить Observable с AuditTime с помощью мрамора RxJs?

У меня есть следующие наблюдаемые:

const obs = obs1.pipe(
  scan(obj, el => ({ ...obj, [el.id]: el }), {}),
  auditTime(100),
  share()
)

И я пытаюсь проверить это с мрамором RxJs:

it(`should generate the stream correctly`, () => {
    ts.run(({ hot, expectObservable }) => {

      const marbles = [
        '-a-----', // obs2 marble
        '100ms x', // expected marble
      ]

      const [obs2Marble, expectedMarble] = marbles

      const obs2EventsMap = {...}

      const expectedMap = {...}

      const mockInput = hot(obs2Marble, obs2EventsMap)

      const obs1$ = require('./obs1').default
      expectObservable(obs1$).toBe(expectedMarble, expectedMap)
    })
  })

Я ожидаю данные в качестве вывода, но они испускают пустой объект.

Как только я использую throttleTime с конфигурацией по умолчанию, он генерирует передовые данные. Но если я настрою дроссель с {ведущим: ложным, конечный: истинный}, наблюдаемый ничего не выдаст.

0 ответов

Другие вопросы по тегам