Observable.changes -> Observable.distinctUntilChanged;

doc/README.md

@@ -17,7 +17,7 @@ RxLua
   - [fromTable](#fromtabletable-iterator-keys)
   - [fromCoroutine](#fromcoroutinecoroutine)
   - [dump](#dumpname-formatter)
-  - [changes](#changescomparator)
+  - [distinctUntilChanged](#distinctuntilchangedcomparator)
   - [combine](#combineobservables-combinator)
   - [compact](#compact)
   - [concat](#concatsources)
@@ -213,7 +213,7 @@ Subscribes to this Observable and prints values it produces.
 
 ---
 
-#### `:changes(comparator)`
+#### `:distinctUntilChanged(comparator)`
 
 Returns an Observable that only produces values from the original if they are different from the previous value.
 

rx.lua

@@ -206,7 +206,7 @@ end
 -- the previous value.
 -- @arg {function} comparator - A function used to compare 2 values. If unspecified, == is used.
 -- @returns {Observable}
-function Observable:changes(comparator)
+function Observable:distinctUntilChanged(comparator)
   comparator = comparator or util.eq
 
   return Observable.create(function(observer)

src/observable.lua

@@ -121,7 +121,7 @@ end
 -- the previous value.
 -- @arg {function} comparator - A function used to compare 2 values. If unspecified, == is used.
 -- @returns {Observable}
-function Observable:changes(comparator)
+function Observable:distinctUntilChanged(comparator)
   comparator = comparator or util.eq
 
   return Observable.create(function(observer)

tests/changes.lua → tests/distinctUntilChanged.lua

@@ -1,35 +1,35 @@
-describe('changes', function()
+describe('distinctUntilChanged', 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:changes().subscribe).to.fail()
+    expect(observable:distinctUntilChanged().subscribe).to.fail()
   end)
 
   describe('with the default comparator', function()
     it('produces a value if it is the first value or different from the previous', function()
-      local observable = Rx.Observable.fromTable({1, 1, 3, 1, 4, 5, 5, 5}, ipairs):changes()
+      local observable = Rx.Observable.fromTable({1, 1, 3, 1, 4, 5, 5, 5}, ipairs):distinctUntilChanged()
       expect(observable).to.produce(1, 3, 1, 4, 5)
     end)
 
     it('produces the first value if it is nil', function()
-      local observable = Rx.Observable.fromValue(nil):changes()
+      local observable = Rx.Observable.fromValue(nil):distinctUntilChanged()
       expect(observable).to.produce({{}})
     end)
 
     it('produces multiple onNext arguments but only uses the first argument to check for equality', function()
-      local observable = Rx.Observable.fromTable({1, 1, 3, 1, 4, 5, 5, 5}, ipairs, true):changes()
+      local observable = Rx.Observable.fromTable({1, 1, 3, 1, 4, 5, 5, 5}, ipairs, true):distinctUntilChanged()
       expect(observable).to.produce({{1, 1}, {3, 3}, {1, 4}, {4, 5}, {5, 6}})
     end)
   end)
 
   describe('with a custom comparator', function()
     it('produces a value if it is the first value or the comparator returns false when passed the previous value and the current value', function()
-      local observable = Rx.Observable.fromTable({1, 1, 3, 1, 4, 5, 5, 5}, ipairs):changes(function(x, y) return x % 2 == y % 2 end)
+      local observable = Rx.Observable.fromTable({1, 1, 3, 1, 4, 5, 5, 5}, ipairs):distinctUntilChanged(function(x, y) return x % 2 == y % 2 end)
       expect(observable).to.produce(1, 4, 5)
     end)
 
     it('produces the first value if it is nil', function()
-      local observable = Rx.Observable.fromValue(nil):changes(function(x, y) return true end)
+      local observable = Rx.Observable.fromValue(nil):distinctUntilChanged(function(x, y) return true end)
       expect(observable).to.produce({{}})
     end)
   end)

tests/observable.lua

@@ -150,11 +150,11 @@ describe('Observable', function()
   describe('dump', function()
   end)
 
-  dofile('tests/changes.lua')
   dofile('tests/combine.lua')
   dofile('tests/compact.lua')
   dofile('tests/concat.lua')
   dofile('tests/distinct.lua')
+  dofile('tests/distinctUntilChanged.lua')
   dofile('tests/filter.lua')
   dofile('tests/find.lua')
   dofile('tests/first.lua')