RxLua/tests/startWith.lua

describe('startWith', function()
  it('produces errors emitted by the source', function()
    expect(Rx.Observable.throw():startWith(1).subscribe).to.fail()
  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)