Test Observable.compact;

tests/compact.lua

@@ -0,0 +1,20 @@
+describe('compact', function()
+  it('produces an error if its parent errors', function()
+    local observable = Rx.Observable.fromValue(''):map(function(x) return x() end)
+    expect(observable.subscribe).to.fail()
+    expect(observable:compact().subscribe).to.fail()
+  end)
+
+  it('does not produce values that are false or nil', function()
+    local observable = Rx.Observable.create(function(observer)
+      observer:onNext(nil)
+      observer:onNext(true)
+      observer:onNext(false)
+      observer:onNext('')
+      observer:onNext(0)
+      observer:onComplete()
+    end)
+
+    expect(observable:compact()).to.produce(true, '', 0)
+  end)
+end)

tests/observable.lua

@@ -150,4 +150,5 @@ describe('Observable', function()
 
   dofile('tests/changes.lua')
   dofile('tests/combineLatest.lua')
+  dofile('tests/compact.lua')
 end)