|
@@ -191,8 +191,8 @@ describe('Observable', function()
|
|
|
local onNextB = observableSpy(observable)
|
|
|
repeat Rx.scheduler:update()
|
|
|
until Rx.scheduler:isEmpty()
|
|
|
- expect(onNextA).to.equal({{2}})
|
|
|
- expect(onNextB).to.equal({{1}, {3}})
|
|
|
+ expect(onNextA).to.equal({{1}, {3}})
|
|
|
+ expect(onNextB).to.equal({{2}})
|
|
|
end)
|
|
|
|
|
|
it('uses a unique coroutine for each Observer when the first argument is a function', function()
|