RxLua/tests/startWith.lua

10 lines
368 B
Lua

describe('startWith', function()
it('produces errors emitted by the source', function()
expect(Rx.Observable.throw():startWith(1)).to.produce.error()
end)
it('produces all specified elements in a single onNext before producing values normally', function()
expect(Rx.Observable.fromRange(3, 4):startWith(1, 2)).to.produce({{1, 2}, {3}, {4}})
end)
end)