RxLua/tests/zip.lua

describe('zip', function()
  it('behaves as an identity function if only one Observable argument is specified', function()
    expect(Rx.Observable.fromRange(1, 5):zip()).to.produce(1, 2, 3, 4, 5)
  end)

  it('unsubscribes from all input observables', function()
    local unsubscribeA = spy()
    local subscriptionA = Rx.Subscription.create(unsubscribeA)
    local observableA = Rx.Observable.create(function(observer)
      return subscriptionA
    end)

    local unsubscribeB = spy()
    local subscriptionB = Rx.Subscription.create(unsubscribeB)
    local observableB = Rx.Observable.create(function(observer)
      return subscriptionB
    end)

    local subscription = Rx.Observable.zip(observableA, observableB):subscribe()
    subscription:unsubscribe()
    expect(#unsubscribeA).to.equal(1)
    expect(#unsubscribeB).to.equal(1)
  end)

  it('groups values produced by the sources by their index', function()
    local observableA = Rx.Observable.fromRange(1, 3)
    local observableB = Rx.Observable.fromRange(2, 4)
    local observableC = Rx.Observable.fromRange(3, 5)
    expect(Rx.Observable.zip(observableA, observableB, observableC)).to.produce({{1, 2, 3}, {2, 3, 4}, {3, 4, 5}})
  end)

  it('tolerates nils', function()
    local observableA = Rx.Observable.create(function(observer)
      observer:onNext(nil)
      observer:onNext(nil)
      observer:onNext(nil)
      observer:onCompleted()
    end)
    local observableB = Rx.Observable.fromRange(3)
    local onNext = observableSpy(Rx.Observable.zip(observableA, observableB))
    expect(#onNext).to.equal(3)
  end)
end)