Как проверить 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 с конфигурацией по умолчанию, он генерирует передовые данные. Но если я настрою дроссель с {ведущим: ложным, конечный: истинный}, наблюдаемый ничего не выдаст.